Rxjava-mathematical-operators
提供:Dev Guides
RxJava-数学演算子
以下は、Observableによって放出されるアイテム全体を操作する演算子です。
Sr.No. | Operator & Description |
---|---|
1 |
Average すべてのアイテムの平均を評価し、結果を出力します。 |
2 |
Concat インターリーブせずに複数のObservableからすべてのアイテムを発行します。 |
3 |
Count すべてのアイテムをカウントし、結果を出力します。 |
4 |
Max すべてのアイテムの最大値アイテムを評価し、結果を出力します。 |
5 |
Min すべてのアイテムの最小値アイテムを評価し、結果を出力します。 |
6 |
Reduce 各アイテムに関数を適用し、結果を返します。 |
7 |
Sum すべてのアイテムの合計を評価し、結果を出力します。 |
数学演算子の例
C:\> RxJavaなどで選択したエディターを使用して、次のJavaプログラムを作成します。
ObservableTester.java
import io.reactivex.Observable;
//Using concat operator to operate on multiple Observables
public class ObservableTester {
public static void main(String[] args) throws InterruptedException {
Integer[] numbers = { 1, 2, 3, 4, 5, 6};
String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
final StringBuilder result = new StringBuilder();
Observable<String> observable1 = Observable.fromArray(letters);
Observable<Integer> observable2 = Observable.fromArray(numbers);
Observable.concat(observable1, observable2)
.subscribe( letter -> result.append(letter));
System.out.println(result);
}
}
結果を確認する
次のように javac コンパイラを使用してクラスをコンパイルします-
C:\RxJava>javac ObservableTester.java
今ObservableTesterを次のように実行します-
C:\RxJava>java ObservableTester
それは次の出力を生成する必要があります-
abcdefg123456