OSMCities.java 文件源码

private Observable<OSMCity> getCities(final String _search) {
    return Observable.create(new Observable.OnSubscribe<OSMCity>() {

        @Override
        public void call(Subscriber<? super OSMCity> arg0) {
            try {
                arg0.onStart();
                JsonNode json = Unirest
                        .get("https://nominatim.openstreetmap.org/search.php?format=json&q=" + _search)
                        .asJson()
                        .getBody();

                JSONArray array = json.getArray();

                for (int i = 0; i < array.length(); i++) {
                    arg0.onNext(new OSMCity(array.getJSONObject(i)));
                }
                arg0.onCompleted();

            } catch (UnirestException ex) {
                arg0.onError(ex);
            }
        }
    });
}