RxJava: Erstellen von Klasseninstanz-Weiß, das auf Observables-Kette läuft

Question

Ich habe einen Code, der RxJava verwendet, um eine XML-Datei zu analysieren. Immer wenn ein neues XML-Tag gelesen wird -> onNext (event_data) wird ausgelöst.

Ich möchte eine Klassenentität auf "START_DOCUMENT" zuweisen und es mit XML-analysierten Attributen füllen.

Mein Problem ist, dass ich im RxJava-Flow darum kämpfe, weil es nicht Teil der Observables-Kette ist. Ich weiß nicht, wie ich die Instanz zuweisen soll, damit sie von den Observablen aus zugänglich ist und wie der Kontext erhalten bleibt.

Hier ist mein Code:

Link to Gist with code sample

Thank you!

Answer 1

Schauen Sie sich scan oder reduce an. Sie erlauben es Ihnen, mit jeder Emission einen Zustand durchzustehen und bei Vollendung diesen Zustand auszusenden. scan gibt die Zwischenzustände und den Abschlusszustand aus und reduce gibt nur den Abschlusszustand aus. Klingt so, als würdest du reduce benutzen.