単一RxJavaは、オブジェクト

Question

を抽出する方法を私はシングル

Single<HotelResult> observableHotelResult = 
          apiObservables.getHotelInfoObservable(requestBody); 

final HotelResult[] hotelResults = new HotelResult[1]; 
    singleHotelResult 
      .subscribe(hotelResult -> { 
       hotelResults[0] = hotelResult; 
      }); 

それとも

final HotelResult hotelResult = singleHotelResult 
            .toBlocking() 
            .value(); 

それは、私たちが.toBlockingメソッドを使用しないでくださいマニュアルに書かれているから値を取得するには、2つの方法を考えることができます。

だから我々は、我々はすぐに結果を取得、その後toBlockingを使用する場合は値

Answer 1

を得るために任意のより良い方法があります。 subscribeを使用すると、結果は非同期で取得されます。遮断する場合については

Single<HotelResult> observableHotelResult = 
    apiObservables.getHotelInfoObservable(requestBody); 

final HotelResult[] hotelResults = new HotelResult[1]; 
singleHotelResult.subscribe(hotelResult -> { 
    hotelResults[0] = hotelResult; 
}); 
// hotelResults[0] may be not initialized here yet 
// println not show result yet (if operation for getting hotel info is long) 
System.out.println(hotelResults[0]); 

：あなたはあなたの場所に結果を持っている必要があり、「正常な」コードで観測を使用しているとき

final HotelResult hotelResult = singleHotelResult.toBlocking().value(); 
// hotelResult has value here but program workflow will stuck here until API is being called. 

toBlockingは例に役立ちます。あなたも、（あなたが購読する必要があります）、それを阻止することは推奨されませんなど

Answer 2

無効にボタンを作り、ページ上のショーの結果のようなsubscribeでいくつかのアクションを設定することができたときに

subscribeは、Androidのアプリケーションで、たとえばあなたを助けますRxJava v2では、ブロッキングのためのメソッドblockingGet（）が、すぐにオブジェクトを返します。