RxJava - tworzenie operatorów

Poniżej znajdują się operatory, które są używane do tworzenia Observable.

Sr.No.	Operator i opis
1	Create Tworzy Observable od podstaw i umożliwia programowe wywoływanie metody obserwatora.
2	Defer Nie twórz Observable, dopóki obserwator nie zasubskrybuje. Tworzy nowe obserwowalne dla każdego obserwatora.
3	Empty/Never/Throw Tworzy Observable z ograniczonym zachowaniem.
4	From Konwertuje strukturę obiektu / danych na Observable.
5	Interval Tworzy obserwowalne emitujące liczby całkowite w kolejności z przerwą o określonym przedziale czasu.
6	Just Konwertuje strukturę obiektu / danych na Observable, aby emitować ten sam lub ten sam typ obiektów.
7	Range Tworzy Observable emitujące liczby całkowite w sekwencji podanego zakresu.
8	Repeat Tworzy Observable emitując liczby całkowite wielokrotnie.
9	Start Tworzy Observable, aby emitować wartość zwracaną przez funkcję.
10	Timer Tworzy Observable, aby wyemitować pojedynczy element po określonym opóźnieniu.

Tworzenie przykładu operatora

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 fromArray operator to create 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
         .map(String::toUpperCase)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}