Anrufe nacheinander mit RXJava tätigen

Question

Ich muss Daten anzeigen, die aus meiner Datenbank kommen, wenn der Benutzer die App startet (sie sind sofort verfügbar), und dann muss ich sie durch Daten ersetzen, die aus dem Netzwerk kommen wie sie verfügbar sind.

habe ich versucht, dies zu tun, dass:

mDisposable = mRepository.getHighlights(forceReload) 
     .subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .subscribeWith(new DisposableObserver<PaginatedData<List<Article>>>() { 
      @Override 
      public void onNext(PaginatedData<List<Article>> articles) { 
       mView.updateData(articles.getData(), articles.isFirstPage(), articles.isLastPage()); 
      } 

      @Override 
      public void onError(Throwable e) { 

      } 

      @Override 
      public void onComplete() { 
      } 
     }); 

und die getHighlights() -Methode:

return Observable.concat(getHighlightsFromDataBase(), getHighlightsFromNetwork()).map(new Function<List<ArticleResponse>, PaginatedData<List<ArticleResponse>>>() { 
      @Override 
      public PaginatedData<List<ArticleResponse>> apply(@NonNull List<ArticleResponse> articleResponses) throws Exception { 
       // ... 
      } 
     }); 

Das Problem ist, dass es nur Anrufe "apply()" (in der "Karte" Methode), wenn getHighlightsFromDataBase() UND getHighlightsFromNetwork() ausgeführt werden.

Anstatt also diese Reihenfolge aufweist:

getHighlightsFromDataBase() 
getHighlightsFromNetwork() 
map() 
onNext() 
map() 
onNext() 

Ich habe müssen:

getHighlightsFromDataBase() 
map() 
onNext() 
getHighlightsFromNetwork() 
map() 
onNext() 

Die "OnNext", die ich über ist die OnNext der Methode, die getHighlights nennt rede(); (damit ich die Ansicht jedes Mal aktualisieren kann, wenn ich neue Daten habe).

Was kann ich tun, um das zu erreichen?

Danke!

Answer 1

So ähnlich?

getHighlightsFromDataBase().map().doOnNext() {  
     getHighlightsFromNetwork().map().onNext() 
    }