RxJava - 组合运算符
以下是用于从多个 Observable 创建单个 Observable 的运算符。
| Sr.No. | 运算符 &描述 |
|---|---|
| 1 |
And/Then/When
使用 Pattern 和 Plan 中介合并项目集。 |
| 2 |
CombineLatest
通过指定函数合并每个 Observable 发出的最新项目并发出结果项目。 |
| 3 |
Join
如果在第二个 Observable 发出项目的时间范围内发出，则合并两个 Observable 发出的项目。 |
| 4 |
Merge
合并 Observables 发出的项目。 |
| 5 |
StartWith
在开始从源 Observable 发出项目之前，发出指定的项目序列 |
| 6 |
Switch
发出 Observable 发出的最新项目。 |
| 7 |
Zip
根据功能组合 Observable 的项目并发出结果项目。 |
组合运算符示例
使用您的任何编辑器创建以下 Java 程序选择，例如，C:\> RxJava。
ObservableTester.java
import io.reactivex.Observable;
//使用combineLatest运算符组合Observables
public class ObservableTester {
public static void main(String[] args) {
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.combineLatest(observable1, observable2, (a,b) -> a + b)
.subscribe( letter -> result.append(letter));
System.out.println(result);
}
}
验证结果
使用 javac 编译器编译类，如下所示 −
C:\RxJava>javac ObservableTester.java
现在运行 ObservableTester，如下所示 −
C:\RxJava>java ObservableTester
它应该产生以下输出 −
g1g2g3g4g5g6
