2016-04-07 16 views
2

Ich versuche, einen unendlichen Strom von beiden bei nächsten und bei Fehleraufrufen zu ermöglichen.RxJava erlauben mehrere onError-Aufrufe

Der folgende Code verwendet die retry() Methode, die ich mir erlauben würde, alle 3 Anrufe zu onNext zu sehen, aber nach dem Fehler nichts anderes aufgerufen wird.

Mein idealer Anwendungsfall würde es mir ermöglichen, alle Fehler und alle nächsten Anrufe aus dem Betreff/Observable zu abonnieren und Maßnahmen zu ergreifen.

Ich habe auch versucht, eine Lösung mit einem benutzerdefinierten Operator wie gezeigt here zu implementieren, aber ich hatte auch kein Glück damit.

Ist es eine Möglichkeit zu erreichen, was ich vorhabe oder das Design von RxJavas onError, das die Kette bricht, blockiert diese Idee vollständig.

Antwort

5

Wie in diesem Thread (Rxjava discussion) erwähnt, ist dies nicht möglich.

Umbrechen Sie den Fehler in eine Nachricht über OnNext, wenn der Fehler den Stream nicht beenden soll.