單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方法的文檔中的值。

那麼，有沒有更好的方式來獲得價值

Answer 1

當我們使用toBlocking那麼我們馬上得到結果。當我們使用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幫助的情況下，當您在「正常」的代碼，你需要有結果的地方使用觀測量。

subscribe幫助您例如在Android應用程序時，你可以設置像演藝結果subscribe一些動作的網頁上，請禁用按鈕等

Answer 2

即使不建議阻止它（你應該訂閱）在RxJava v2中，阻塞的方法是blockingGet（），它立即返回對象。