Gibt es in RxJava/RxAndroid eine Möglichkeit, die Kette der Operatoren auch nach dem Abmelden zu beenden?

Question

Grundsätzlich habe ich eine Kette, wo ich meine API aufrufen und es gibt ein Ergebnis zurück, das ich verwenden, um meine lokale Datenbank zu aktualisieren. Schließlich, nachdem das erledigt ist, habe ich Code in meinem onNext(), um die UI zu aktualisieren. Wenn der Benutzer die Aktivität schließt, muss ich den Abmeldeservice aufrufen, aber das könnte bedeuten, dass meine Datenbank möglicherweise nicht aktualisiert wird. Gibt es eine Möglichkeit, das sicherzustellen?

Answer 1

Ja, Sie können doOnNext().publish().autoConnect() verwenden. Die doOnNext sollte die Datenbank speichern Logik und der Rest stellt sicher, dass es ausgeführt wird, auch wenn der Abonnent abgemeldet.