RxJava - Ausführen einer peek() - oder void-Operation in einer Observable-Kette?

Question

Java 8-Lambda-Streams verfügen über einen peek()-Operator, mit dem Sie eine Leeroperation für jedes Element ausführen können. Dies wird normalerweise zum Debuggen verwendet, aber es ist auch eine gute Möglichkeit, eine void-Operation zu betrügen und zu starten, ohne etwas zuzuordnen.

Gibt es eine Entsprechung in RxJava? Vielleicht folge ich nicht einer guten Übung oder denke reaktiv genug nach ... aber es wäre wirklich praktisch, Status-Etiketten vor und nach einer Operation zu erstellen? Wenn peek() nicht unterstützt wird, gibt es ein besseres Muster zu folgen?

Answer 1

Es gibt eine Methode doOnNext(Action1<Item> action), die für jedes Element im Stream aufgerufen wird.

Documentation