RxJava - 数学运算符
以下是操作 Observable 发出的整个项目的运算符。
| Sr.No. | 运算符 &描述 |
|---|---|
| 1 | Average 计算所有项目的平均值并发出结果。 |
| 2 | Concat 从多个 Observable 中发出所有项目，不进行交错。 |
| 3 | Count 计算所有项目并发出结果。 |
| 4 | Max 计算所有项目中的最大值并发出结果。 |
| 5 | Min 计算所有项目中最小值的项目并发出结果。 |
| 6 | Reduce 对每个项目应用一个函数并返回结果。 |
| 7 | Sum 计算所有项目的总和并发出结果。 |
数学运算符示例
使用您选择的任何编辑器在 C:\> 中创建以下 Java 程序RxJava。
ObservableTester.java
import io.reactivex.Observable;
//使用 concat 运算符对多个 Observable 进行操作
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
