连续可观察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);