Rxjava 简明教程
RxJava - Combining Operators
以下是用于从多个 Observable 中创建单个 Observable 的操作符。
Sr.No. |
Operator & Description |
1 |
*And/Then/When*使用模式和计划中介结合项集。 |
2 |
*CombineLatest*通过指定函数结合每个 Observable 发出的最新项，并发出结果项。 |
3 |
*Join*结合两个 Observable 发出的项，如果是在第二个 Observable 发出项的时间范围内发出的。 |
4 |
*Merge*结合 Observable 发出的项。 |
5 |
*StartWith*在开始发出源 Observable 项之前，先发出一个指定项序列 |
6 |
*Switch*发出 Observable 发出的最新项。 |
7 |
*Zip*根据函数结合 Observable 的项，并发出结果项。 |
Combining Operator Example
在任意编辑器中使用任何您选择的语言（如 C:\>RxJava) 创建以下 Java 程序。
ObservableTester.java
import io.reactivex.Observable;
//Using combineLatest operator to combine 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);
}
}