mainThreadのcombineLatest（）関数

Question

私は2つの観測値を結合し、AndroidSchedules.mainThread（）で "combine関数"を実行したいと考えています。 .observeOn（AndroidSchedules.mainThread（））を追加しましたが、 "java.lang.IllegalStateException：メインスレッドではありません"というメッセージが表示されます。

Observable<List<Post>> animateCameraAndGetPostsByProjection = Observable.combineLatest(
      mapObservableProvider.getMapReadyObservable(), 
      LocationService.getUpdatedOrLastKnownLocation(this), 
      (googleMap, location) -> { 
       CameraUpdate cameraUpdate = CameraUpdateFactory.newLatLngZoom(new LatLng(location.getLatitude(),location.getLongitude()),15); 
       googleMap.moveCamera(cameraUpdate); 
       return googleMap.getProjection().getVisibleRegion(); 
      }) 
      .flatMap(vr -> new RestService().getApi().getPostsByMapProjection(vr.farLeft.latitude,vr.farLeft.longitude,vr.nearRight.latitude,vr.nearRight.longitude)) 
      .observeOn(AndroidSchedulers.mainThread()); 

Answer 1

この場合、2つの値をペアにしてメインスレッドに送信する必要があります。

Observable<List<Post>> animateCameraAndGetPostsByProjection = Observable.combineLatest(
    mapObservableProvider.getMapReadyObservable(), 
    LocationService.getUpdatedOrLastKnownLocation(this), 
    (googleMap, location) -> Pair.of(googleMap, location) 
) 
.observeOn(AndroidSchedulers.mainThread()) 
.map(pair -> { 
    CameraUpdate cameraUpdate = CameraUpdateFactory 
     .newLatLngZoom(new LatLng(pair.second.getLatitude(), 
       pair.second.getLongitude()),15); 
    pair.first.moveCamera(cameraUpdate); 
    return googleMap.getProjection().getVisibleRegion();   
}) 
.flatMap(vr -> new RestService().getApi() 
    .getPostsByMapProjection(vr.farLeft.latitude,vr.farLeft.longitude, 
     vr.nearRight.latitude,vr.nearRight.longitude) 
) 
.observeOn(AndroidSchedulers.mainThread());