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);
}
}
Sprawdź wynik
Skompiluj klasę przy użyciu javac kompilator w następujący sposób -
C:\RxJava>javac ObservableTester.java
Teraz uruchom ObservableTester w następujący sposób -
C:\RxJava>java ObservableTester
Powinien dać następujący wynik -
ABCDEFG