Rxjava -

Question

我在RxJava有當製片人（API請求）發射事件過快，消費（API響應）一個奇怪的問題熱觀測只獲得了API請求的第二個響應。

比方說，我有一對夫婦需要向服務器發送查詢數據庫的請求，因爲一些來自服務器的查詢需要一定的時間。所以當我得到迴應時，第二個請求可能會首先返回，而奇怪的是有時候我沒有得到第一個請求的響應。

這使得API調用的代碼：

public void sendRequests() { 
    // using RxJava to make server polling. 
    startPollingServer(); 
} 

的startPollingServer（）方法是使用RxJava從服務器輪詢數據。

public void startPollingServer() { 
    mApiService.getPollingFromServer() 
     .retryWhen() 
     .repeatWhen() 
     .map() 
     .subscribeOn() 
     .observeOn() 
     .subscribe(
      // call onNext 
      // call onError 
     ) 
} 

然而，當sendRequests（）是調用太快，既不onNext，的onComplete，onError的被稱爲。第一次請求沒有任何事情發生。 但是我確實得到了CharlesProxy的第一個迴應，這真的很奇怪。

所以我的問題是，有沒有可能RxJava不理會我的第一反應？我需要合併來自startPollingServer（）的Observables嗎？

Answer 1

據我2年以上與RxJava經驗它是非常不太可能失去一些數據。 考慮下面的事情：

誤差被抑制

使用retryWhen和repeatWhen可能導致錯誤的抑制，嘗試添加 '的onError（）' 操作，以便對付那些：

public void startPollingServer() { 
    mApiService.getPollingFromServer() 
     .doOnError(throwable -> log.error("Got an error", throwable)) // catch error 
     .retryWhen() 
     .repeatWhen() 
     .map() 
     .subscribeOn() 
     .observeOn() 
     .subscribe(
      // call onNext 
      // call onError 
     ) 
} 

http://reactivex.io/RxJava/javadoc/rx/Observable.html#doOnError(rx.functions.Action1)

不正確的平行度

Observable.just(1,2,3) 
.flatMap(i -> doNetworkCall(i)) 
.first() 

這樣的代碼可能會導致的「doNetworkCall（I）」，其中第二應答可能會比第一速度更快的並行執行。爲了驗證，使用 'concatMap' 來代替，這保證了與被處理的流的順序：http://reactivex.io/documentation/operators/concat.html

調試

算 'doOnNext（）'， 'doOnSubscribe（）'， 'doOnCompleted（）' 和' doOnError（）'可能會幫助您找到錯誤

Observable.just(1,2,3) 
.flatMap(i -> doNetworkCall(i) 
      .doOnSubscribe(() -> log.debug("Launched {}", i)) 
      .doOnNext(response -> log.debug("Got response {} for {}", response, i)) 
      .doOnError(throwable -> log.error("For error for " + i, throwable)) 
      .doOnComplete(() -> log.info("Finished processing of {}", i)) 
) 
.first()