RxJava - 实用运算符
以下是通常对 Observable 有用的运算符。
| Sr.No. | 运算符 &描述 |
|---|---|
| 1 | Delay 注册操作以处理 Observable 生命周期事件。 |
| 2 | Materialize/Dematerialize 表示发出的项目和发送的通知。 |
| 3 | ObserveOn 指定要观察的调度程序。 |
| 4 | Serialize 强制 Observable 进行序列化调用。 |
| 5 | Subscribe 对 Observable 发出的项目和通知(如完成)进行操作 |
| 6 | SubscribeOn 指定订阅 Observable 时要使用的调度程序。 |
| 7 | TimeInterval 将 Observable 转换为发出两次发射之间经过的时间量的指示。 |
| 8 | Timeout 如果在指定时间内没有发出任何项目，则发出错误通知。 |
| 9 | Timestamp 将时间戳附加到发出的每个项目。 |
| 10 |
Using 创建一次性资源或与 Observable 相同的生命周期。 |
实用程序运算符示例
使用您选择的任何编辑器在 C:\> 中创建以下 Java 程序RxJava。
ObservableTester.java
import io.reactivex.Observable;
//使用订阅运算符订阅 Observable
public class ObservableTester {
public static void main(String[] args) {
String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
final StringBuilder result = new StringBuilder();
Observable<String> observable = Observable.fromArray(letters);
observable.subscribe( letter -> result.append(letter));
System.out.println(result);
}
}
验证结果
使用 javac 编译器编译类，如下所示 −
C:\RxJava>javac ObservableTester.java
现在运行 ObservableTester，如下所示 −
C:\RxJava>java ObservableTester
它应该产生以下输出 −
abcdefg
