RxJava Netzwerkanforderungen und Caching

Question

Ich suche ein Beispiel für einen Fluss, den ich mit Hilfe von RxJava implementieren möchte.

Angenommen, ich möchte eine Liste von Daten anzeigen. Der Ablauf sollte in etwa so aussehen:

1. Cache lesen. Wenn es die Daten enthält, zeigen Sie es an;

2. eine API-Anfrage an den Server senden:

   Wenn es die Daten zurückgegeben, es dann und es zeigen zwischenzuspeichern.

   Wenn es zurückgegeben und Fehler, und es gab keine im Cache gespeicherten Daten zeigen dann einen Fehler.

   Wenn es zurückgegeben und Fehler und es war etwas im Cache gespeichert, dann nichts zu tun.

Im Moment habe ich ein method that does something similar (mit viel Inspiration von Jake's u2020). Der Hauptunterschied besteht darin, dass das In-Memory-Caching verwendet wird, so dass kein separates Observable zum Lesen aus dem Cache benötigt wird. Dies kann auch synchron erfolgen.

Ich weiß nicht, wie zwei Observablen kombinieren (eine für aus dem Cache und die andere für API-Aufruf zu lesen) und die oben beschriebene Strömung erhalten.

Irgendwelche Vorschläge?

Answer 1

Hier ist meine Lösung:

readDataFromCache().defaultIfEmpty(null) 
     .flatMap(new Func1<Data, Observable<Data>>() { 

      @Override 
      public Observable<Data> call(final Data data) { 
       if (data == null) { 
        // no cache, show the data from network or throw an error 
        return apiCall(); 
       } else { 
        return Observable.concat(
          Observable.just(data), 
          // something cached, show the data from network or do nothing. 
          apiCall().onErrorResumeNext(Observable.<Data>empty())); 
       } 
      } 
     }); 

ich nicht hinzufügen, die subscribeOn und observeOn, weil ich nicht sicher bin, readDataFromCache()ioScheduler oder uiScheduler verwenden sollten.

Answer 2

Ich glaube, ich habe mein Problem gelöst. Die beobachtbare Kette sieht so aus:

apiCall() 
     .map(data -> dataInMemory = data) 
     .onErrorResumeNext(t -> data == null ? 
       Observable.just(Data.empty()) : Observable.empty()) 
     .startWith(readDataFromCache().map(data -> dataInMemory = data)) 
     .subscribeOn(ioScheduler) 
     .observeOn(uiScheduler) 
     .subscribe(dataRequest); 

Der wichtigste Punkt ist, dass, wenn readDataFromCache() einen Fehler wirft, wird es onCompleted() aufrufen, ohne onError() aufrufen. Es sollte also eine benutzerdefinierte Observable sein, die Sie steuern können.

Data.empty() ist ein Stub für meine Daten - die Subscriber sollte es als Fehler behandeln.

dataInMemory ist Mitglied in meiner Steuerung, die im Cache-Speicher fungiert.

---

EDIT: die Lösung nicht richtig funktioniert. Der Abschluss eines Anwendungsfalles (siehe Kommentar) wird nicht erreicht.

EDIT 2: gut, die Lösung funktioniert funktioniert nach einigen Feinabstimmungen. Der Fix gab verschiedene Typen von Observablen zurück, abhängig vom Status des In-Memory-Caches. Irgendwie schmutzig.