RxJava 实用操作符|极客教程

RxJava 实用操作符

以下是在 Observables 中经常使用的操作符。

序号	操作符和说明
1	Delay 注册一个操作以处理Observable的生命周期事件。
2	Materialize/Dematerialize 表示发出的项和发送的通知。
3	ObserveOn 指定要观察的调度器。
4	Serialize 强制Observable进行序列化调用。
5	Subscribe 对Observable的发射项和通知（如来自Observable的complete）进行操作。
6	SubscribeOn 指定Observable在被订阅时所使用的调度器。
7	TimeInterval 将Observable转换为发出时间间隔指示的形式。
8	Timeout 如果指定的时间过去但没有发出任何项，则发出错误通知。
9	Timestamp 为每个发出的项附加时间戳。
10	Using 创建可释放的资源，或与Observable具有相同的生命周期。

实用操作符示例

使用您选择的编辑器，在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);
   }
}