RxJava - Operatorzy narzędzi

Poniżej znajdują się operatory, które są często przydatne w przypadku Observables.

Sr.No.	Operator i opis
1	Delay Zarejestruj akcję, aby obsłużyć obserwowalne zdarzenia cyklu życia.
2	Materialize/Dematerialize Reprezentuje wysłany element i wysłane powiadomienie.
3	ObserveOn Określ planistę, który ma być obserwowany.
4	Serialize Wymuś obserwowalne, aby wykonywać szeregowane wywołania.
5	Subscribe Działaj na emisjach przedmiotów i powiadomień, takich jak kompletne z Obserwowalnego
6	SubscribeOn Określ harmonogram, który ma być używany przez Observable, gdy jest subskrybowany.
7	TimeInterval Konwertuj obserwowalne, aby emitować wskazania czasu, jaki upłynął między emisjami.
8	Timeout Wysyła powiadomienie o błędzie, jeśli określony czas wystąpi bez emitowania żadnego elementu.
9	Timestamp Dołącz sygnaturę czasową do każdego emitowanego elementu.
9	Using Tworzy zasób jednorazowego użytku lub taką samą żywotność jak Observable.

Przykład operatora mediów

Utwórz następujący program w języku Java, używając dowolnego wybranego edytora, na przykład w 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);
   }
}