Returnコールバックで観測可能rxjava

Question

私はGoogleの意識のAPIをいくつか取り乱しています。今ではRxJavaの理解が私を制限しています。

最後に達成したいこと： 私は天気と場所をApiから取得し、それらを1つのオブジェクトに結合して更新のために渡すことができます。

しかし、戻り値の型がvoidであることからapiコールバックからObservableをどのように返すか、api.getWeatherとapi.getLocationからweatherオブジェクトとlocationオブジェクトをマージする方法はわかりません私のプロジェクトで私の他のもののため

public void requestUserCurrentInfo() { 
    Subscription userInfo = getWeatherLocation().subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()).subscribe(userinfo -> 
        Log.d(TAG,userinfo.something())); 
} 

public Observable<UserInfo> getWeatherLocation() { 
    try { 
     Awareness.SnapshotApi.getWeather(client) 
       .setResultCallback(weather -> { 
        if (!weather.getStatus().isSuccess()) { 
         Log.d(TAG, "Could not get weather"); 
         return; 
        } 
        //How do I do here? 
        return weather.getWeather(); 
       }); 


     Awareness.SnapshotApi.getLocation(mGoogleApiClient) 
      .setResultCallback(retrievedLocation -> { 
       if(!retrievedLocation.getStatus().isSuccess()) return; 
       Log.d("FRAG", retrievedLocation.getLocation().getLatitude() + ""); 
      }); 


    } catch (SecurityException exception) { 
     throw new SecurityException("No permission " + exception); 

    } 

} 

、私はすべてのステップが観察< SmhiResponseを返すため、私はこのようにそれを得ることができ、リポジトリパターン以下のREST APIを介していくつかのものを得る>

getWeatherSubscription = getWeatherUsecase.execute().subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()).subscribe(
        smhiResponseModel -> {Log.d(TAG,"Retrieved weather"); locationView.hideLoading();}, 
        err -> {Log.d(TAG,"Error fetching weather"); locationView.hideLoading();} 
      ); 

Answer 1

を観測あなたは、コールバックから、観察を返しますが（未テスト）それらを組み合わせ可能にするために観測にあなたのコールバックをラップしていない：

Observable<WeatherResult> weatherObservable = Observable.create(subscriber -> { 
     Awareness.SnapshotApi.getWeather(client) 
       .setResultCallback(weather -> { 
        if (!weather.getStatus().isSuccess()) { 
         subscriber.onError(new Exception("Could not get weather.")); 
         Log.d(TAG, "Could not get weather"); 
        } else { 
         //How do I do here? 

         subscriber.onNext(weather); 
         subscriber.onCompleted(); 
        } 
       }); 
    }); 

    Observable<LocationResult> locationObservable = Observable.create(subscriber -> { 
     Awareness.SnapshotApi.getLocation(mGoogleApiClient) 
       .setResultCallback(retrievedLocation -> { 
        if(!retrievedLocation.getStatus().isSuccess()) { 
         subscriber.onError(new Exception("Could not get location.")); 
        } else { 
         Log.d("FRAG", retrievedLocation.getLocation().getLatitude() + ""); 
         subscriber.onNext(retrievedLocation); 
         subscriber.onCompleted(); 
        } 
       }); 
    }); 

は今、それらを組み合わせて.combineLatest()または.zip()経由：

Observable<CombinedResult> combinedResults = Observable.zip(weatherObservable, locationObservable, 
      (weather, location) -> { 
       /* somehow combine weather and location then return as type "CombinedResult" */ 
      }); 

それらのどれもが実行されなかっますそれ以外の場合は、登録することを忘れないでください：

combinedResults.subscribe(combinedResult -> {/*do something with that stuff...*/}); 

Answer 2

Observable.combineLatest(getWeather(), getLocation(), new Func2<List<Object_A>, List<Object_B>, Object>() { 
      @Override 
      public Object call(Object o, Object o2) { 
       combine both results and return the combine result to observer 
      } 
     }) 

getweather（）とのgetLocation（）の戻りが