Последовательный наблюдаемый веб-сервис и запрос на запрос базы данных

Question

Как реализовать последовательный вызов веб-службы и запроса базы данных с использованием RxJava Observable? Первый вызов - это запрос базы данных (кэш), а затем вывод результата (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);