Rxjava-transforming-operators
提供:Dev Guides
RxJava-変換演算子
以下は、Observableから放出されたアイテムを変換するために使用される演算子です。
Sr.No. | Operator & Description |
---|---|
1 |
Buffer Observableからアイテムを定期的にバンドルに収集し、アイテムではなくバンドルを発行します。 |
2 |
FlatMap ネストされたオブザーバブルで使用されます。 アイテムをオブザーバブルに変換します。 次に、アイテムを単一のObservableにフラット化します。 |
3 |
GroupBy Observableをキーごとに編成されたObservableのセットに分割し、アイテムの異なるグループを発行します。 |
4 |
Map 放出される各アイテムに関数を適用して変換します。 |
5 |
Scan 放出された各アイテムに関数を順番に適用し、連続した値を放出します。 |
6 |
Window ObservableからObservableウィンドウにアイテムを定期的に収集し、アイテムではなくウィンドウを放出します。 |
変換演算子の例
C:\> RxJavaなどで選択したエディターを使用して、次のJavaプログラムを作成します。
ObservableTester.java
import io.reactivex.Observable;
//Using map operator to transform 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