Rxjava 简明教程
RxJava - Mathematical Operators
以下是操作 Observable 发出的整个项目的运算符。
Sr.No. |
Operator & Description |
1 |
Average 评估所有项目的平均值并发出结果。 |
2 |
Concat 从多个 Observable 中发出所有项目，不交错。 |
3 |
Count 计算所有项目并发出结果。 |
4 |
Max 评估所有项目的最大值项目并发出结果。 |
5 |
Min 评估所有项目的最小值项目并发出结果。 |
6 |
Reduce 对每个项目应用一个函数并返回结果。 |
7 |
Sum 评估所有项目的总和并发出结果。 |
Mathematical Operator Example
在任意编辑器中使用任何您选择的语言（如 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);
}
}