RxJava 数学运算符
RxJava 数学运算符 介绍
以下是 Observable 的数学运算符。
| 运算符 | 描述 |
|---|---|
| Average | 评估所有项目的平均值并发出结果。 |
| Concat | 不交错地从多个 Observable 发出所有项目。 |
| Count | 计算所有项目并发出结果。 |
| Max | 评估所有项目的最大值项目并发出结果。 |
| Min | 评估所有项目的最小值项目并发出结果。 |
| Reduce | 对每个项目应用一个函数并返回结果。 |
| Sum | 评估所有项目的总和并发出结果。 |
RxJava 数学运算符 示例
package cn.xnip;
import io.reactivex.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);
}
}
输出结果为：
