Rxjava-creating-operators
提供:Dev Guides
RxJava-オペレーターの作成
以下は、Observableを作成するために使用される演算子です。
Sr.No. | Operator & Description |
---|---|
1 |
Create Observableをゼロから作成し、オブザーバーメソッドがプログラムで呼び出すことを許可します。 |
2 |
Defer オブザーバーがサブスクライブするまでObservableを作成しないでください。 各オブザーバーの新しいオブザーバブルを作成します。 |
3 |
Empty/Never/Throw 動作が制限されたObservableを作成します。 |
4 |
From オブジェクト/データ構造をObservableに変換します。 |
5 |
Interval 指定された時間間隔のギャップで、整数を連続して放出するObservableを作成します。 |
6 |
Just オブジェクトまたはデータ構造をObservableに変換して、同じまたは同じタイプのオブジェクトを発行します。 |
7 |
Range 指定された範囲の順序で整数を出力するObservableを作成します。 |
8 |
Repeat 整数を繰り返し放出するObservableを作成します。 |
9 |
Start 関数の戻り値を発行するObservableを作成します。 |
10 |
Timer 指定された遅延後に単一のアイテムを放出するObservableを作成します。 |
オペレーターの作成例
C:\> RxJavaなどで選択したエディターを使用して、次のJavaプログラムを作成します。
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);
}
}
結果を確認する
次のように javac コンパイラを使用してクラスをコンパイルします-
C:\RxJava>javac ObservableTester.java
今ObservableTesterを次のように実行します-
C:\RxJava>java ObservableTester
それは次の出力を生成する必要があります-
ABCDEFG