RxJava - 实用操作符

以下是与可观察对象经常一起使用的操作符。

序号	操作符及描述
1	延时 (Delay) 注册操作以处理可观察对象的生命周期事件。
2	Materialize/Dematerialize 表示发射的项目和发送的通知。
3	ObserveOn 指定要观察的调度器。
4	Serialize 强制可观察对象进行序列化调用。
5	Subscribe 对可观察对象的项目发射和通知（如完成）进行操作。
6	SubscribeOn 指定可观察对象订阅时使用的调度器。
7	TimeInterval 将可观察对象转换为发射项目之间经过时间的指示。
8	Timeout 如果在指定时间内没有发射任何项目，则发出错误通知。
9	Timestamp 为每个发射的项目附加时间戳。
9	使用 (Using) 创建一个与可观察对象具有相同生命周期的可丢弃资源。

实用操作符示例

使用您选择的任何编辑器创建以下 Java 程序，例如在 C:\>RxJava 中。

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);
   }
}

验证结果

使用javac编译器编译类，如下所示：

C:\RxJava>javac ObservableTester.java

现在运行 ObservableTester，如下所示：

C:\RxJava>java ObservableTester

它应该产生以下输出：

abcdefg

打印页面