Reaktive Programmierung mit RxJava

Kapitel 3. Operatoren und Transformationen

Diese Arbeit wurde mithilfe von KI übersetzt. Wir freuen uns über dein Feedback und deine Kommentare: [e-mail]

Tomasz Nurkiewicz

Das Ziel dieses Kapitels ist es, die Grundlagen der RxJava-Operatoren zu erläutern und zu zeigen, wie du sie zusammenstellen kannst, um einfache Datenpipelines auf hohem Niveau zu erstellen. Einer der Gründe, warum RxJava so leistungsfähig ist, ist die Vielzahl der eingebauten Operatoren und die Möglichkeit, eigene Operatoren zu erstellen. Ein Operator ist eine Funktion, die eine vorgelagerte Observable<T> aufnimmt und eine nachgelagerte Observable<R> zurückgibt, wobei die Typen T und R identisch sein können, aber nicht müssen. Mit Operatoren lassen sich einfache Transformationen zu komplexen Verarbeitungsgraphen zusammensetzen.

Der Operator Observable.filter() empfängt z. B. Artikel von einem vorgelagerten Observable, leitet aber nur diejenigen weiter, die einem bestimmten Prädikat entsprechen. Umgekehrt wandelt Observable.map() die empfangenen Elemente um, während sie durchfliegen. So können ursprüngliche Ereignisse extrahiert, angereichert oder verpackt werden. Einige Operatoren sind sehr viel komplexer. Observable.delay() zum Beispiel lässt die Ereignisse unverändert durchlaufen, aber jedes einzelne erscheint nach einer bestimmten Verzögerung. Und schließlich gibt es Operatoren (wie Observable.buffer()), die mehrere Eingangsereignisse verbrauchen, bevor sie sie ausgeben, möglicherweise ...