RxJava 工具运算符
RxJava 工具运算符 介绍
以下是通常对 Observable 工具运算符。
| 运算符 | 描述 |
|---|---|
| Delay | 注册操作以处理 Observable 生命周期事件。 |
| Materialize/Dematerialize | 表示发出的项目和发送的通知。 |
| ObserveOn | 指定要观察的调度程序。 |
| Serialize | 强制 Observable 进行序列化调用。 |
| Subscribe | 操作来自 Observable 的项目和通知的发送 |
| SubscribeOn | 指定 Observable 在订阅时要使用的调度程序。 |
| TimeInterval | 将 Observable 转换为发射之间经过的时间量的指示。 |
| Timeout | 如果发生指定时间而没有发出任何项目，则发出错误通知。 |
| Timestamp | 将时间戳附加到发出的每个项目。 |
| Using | 创建一个一次性资源或与 Observable 相同的生命周期。 |
RxJava 工具运算符 示例
package cn.xnip;
import io.reactivex.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);
}
}
输出结果为：
