Rxjava 简明教程
RxJava - Utility Operators
以下是通常与 Observable 一起使用的操作符。
Sr.No. |
Operator & Description |
1 |
Delay 注册操作以处理 Observable 生命周期事件。 |
2 |
Materialize/Dematerialize 表示已发出的项和发送的通知。 |
3 |
ObserveOn 指定要观察的调度程序。 |
4 |
Serialize 强制 Observable 执行序列化调用。 |
5 |
Subscribe 对 Observable 的项目和通知（如完成）的发出进行操作 |
6 |
SubscribeOn 订阅 Observable 时，指定要使用的调度程序。 |
7 |
TimeInterval 将 Observable 转换为发出两次发出之间经过的时间量指示。 |
8 |
Timeout 如果没有发出任何项目，在指定的时间发生时发出错误通知。 |
9 |
Timestamp 为每个发出的项目附加时间戳。 |
9 |
Using 创建一个与 Observable 具有相同生命周期的可处置资源。 |
Utility Operator Example
在任意编辑器中使用任何您选择的语言（如 C:\>RxJava) 创建以下 Java 程序。
ObservableTester.java
import io.reactivex.Observable;
//Using subscribe operator to subscribe to an 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);
}
}