RxJava 合并运算符
RxJava 合并运算符 介绍
以下是用于从多个 Observable 创建单个 Observable 的运算符。
| 运算符 | 描述 |
|---|---|
| And/Then/When | 使用模式和计划中介组合项目集。 |
| CombineLatest | 通过指定的函数组合每个 Observable 发出的最新项并发出结果项。 |
| Join | 如果在第二个 Observable 发射项目的时间范围内发送，则组合两个 Observable 发送的项目。 |
| Merge | 组合 Observables 发出的项目。 |
| StartWith | 在开始从源 Observable 发出项目之前发出指定的项目序列 |
| Switch | 发出 Observables 发出的最新项目。 |
| Zip | 根据函数组合 Observables 项并发出结果项。 |
RxJava 合并运算符 示例
package cn.xnip;
import io.reactivex.Observable;
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);
}
}
输出结果为：
