0

DB から POI をロードするために Realm を使用します。次にmapsforgeによるクラスター実現にこのポイントを追加します。このコードはうまく機能します:

 RealmResults<GasolineRealm> gasolineRealms = presenter.getRealm().where(GasolineRealm.class)
            .findAll();
    for(int i=0; i<gasolineRealms.size(); i++){
        geoItems.add(new GasolineGeoItem(gasolineRealms.get(i).getId(),
                gasolineRealms.get(i).getLocalizationRealms().get(0).getTitle(),
                gasolineRealms.get(i).getCoordinateLatitude(),
                gasolineRealms.get(i).getCoordinateLongitude()));
        clusterer.addItem(geoItems.get(i));
    }

マップ上にすべての POI を描画しますが、Realm クラスターに RxJava を使用する場合、マップ上に POI を追加しないでください。コードは次のとおりです。

Realm.getDefaultInstance().where(GasolineRealm.class)
            .findAllAsync()
            .asObservable()
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Observer<RealmResults<GasolineRealm>>() {
                @Override
                public void onCompleted() {

                }

                @Override
                public void onError(Throwable e) {

                }

                @Override
                public void onNext(RealmResults<GasolineRealm> gasolineRealms) {
                    for(int i=0; i<gasolineRealms.size(); i++){
                        geoItems.add(new GasolineGeoItem(gasolineRealms.get(i).getId(),
                                gasolineRealms.get(i).getLocalizationRealms().get(0).getTitle(),
                                gasolineRealms.get(i).getCoordinateLatitude(),
                                gasolineRealms.get(i).getCoordinateLongitude()));
                        clusterer.addItem(geoItems.get(i));
                    }
                }
            });
4

1 に答える 1

1

これを行うと、2つはほぼ同等になります

     Subscription subscription = presenter.getRealm().where(GasolineRealm.class)
        .findAllAsync()
        .asObservable()
        .filter(RealmResults::isLoaded)
        .first()
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Observer<RealmResults<GasolineRealm>>() {
            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onNext(RealmResults<GasolineRealm> gasolineRealms) {
                for(int i=0; i<gasolineRealms.size(); i++){
                    GasolineRealm gasolineRealm = gasolineRealms.get(i);
                    geoItems.add(new GasolineGeoItem(gasolineRealm.getId(),
                            gasolineRealm.getLocalizationRealms().get(0).getTitle(),
                            gasolineRealm.getCoordinateLatitude(),
                            gasolineRealm.getCoordinateLongitude()));
                    clusterer.addItem(geoItems.get(i));
                }
            }
        });
于 2016-11-25T18:29:10.340 に答える