RxJava - Dienstprogrammbetreiber

Im Folgenden sind die Operatoren aufgeführt, die bei Observables häufig hilfreich sind.

Sr.Nr.	Betreiber & Beschreibung
1	Delay Registrieren Sie die Aktion, um beobachtbare Lebenszyklusereignisse zu verarbeiten.
2	Materialize/Dematerialize Stellt das ausgegebene Element und die gesendete Benachrichtigung dar.
3	ObserveOn Geben Sie den zu beobachtenden Scheduler an.
4	Serialize Erzwinge Observable, um serialisierte Anrufe zu tätigen.
5	Subscribe Arbeiten Sie mit den Emissionen von Gegenständen und Benachrichtigungen wie vollständig von einem Observable
6	SubscribeOn Geben Sie den Scheduler an, der von einem Observable verwendet werden soll, wenn es abonniert ist.
7	TimeInterval Konvertieren Sie ein Observable, um Angaben zur Zeitspanne zwischen den Emissionen zu machen.
8	Timeout Gibt eine Fehlerbenachrichtigung aus, wenn die angegebene Zeit auftritt, ohne dass ein Element ausgegeben wird.
9	Timestamp Fügen Sie jedem ausgegebenen Objekt einen Zeitstempel hinzu.
9	Using Erstellt eine verfügbare Ressource oder dieselbe Lebensdauer wie Observable.

Beispiel für einen Dienstprogrammbetreiber

Erstellen Sie das folgende Java-Programm mit einem beliebigen Editor Ihrer Wahl, z. B. in C: \> RxJava.

ObservableTester.java

import io.reactivex.Observable;
//Using subscribe operator to subscribe to an Observable
public class ObservableTester  {
   public static void main(String[] args) {    
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      Observable<String> observable = Observable.fromArray(letters);
      observable.subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}