combineLatest() -Funktion auf mainThread

Question

Ich möchte 2 Observablen kombinieren und führen "kombinieren Funktion" auf AndroidSchedules.mainThread(). Ich habe .observeOn (AndroidSchedules.mainThread()) hinzugefügt, bekomme aber immer noch "java.lang.IllegalStateException: Not on the main thread".

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

In diesem Fall müssen Sie die beiden Werte paaren und an den Hauptthread senden.

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());