連續可觀察Web服務和數據庫查詢調用

Question

如何使用RxJava Observable實現順序Web服務和數據庫查詢調用？首先調用數據庫查詢（緩存），然後顯示結果（onNext或onCompleted），之後是網絡調用，然後顯示（替換）當前結果（緩存）。我正在使用Volley和監聽器來顯示數據。

Answer 1

可以使用concat執行順序操作。由於兩個級聯的觀測量可以是不同類型ignoreElements和cast可能是有用的：

databaseQueryObservable 
    .doOnNext(displayResult) 
    .doOnComplete(something) 
    .ignoreElements() 
    .cast(Object.class) 
    .concatWith(
     networkCall 
      .doOnNext(displayNetworkCallResult) 
      .doOnComplete(somethingElse) 
      .ignoreElements() 
      .cast(Object.class) 
    ).subscribe(onNextAction, onErrorAction, onCompletedAction);