RxJava-ユーティリティ演算子

以下は、Observablesでよく役立つ演算子です。

シニア番号	オペレーターと説明
1	Delay 監視可能なライフサイクルイベントを処理するアクションを登録します。
2	Materialize/Dematerialize 放出されたアイテムと送信された通知を表します。
3	ObserveOn 監視するスケジューラーを指定します。
4	Serialize Observableにシリアル化された呼び出しを強制します。
5	Subscribe オブザーバブルからの完了など、アイテムの排出と通知を操作します
6	SubscribeOn サブスクライブ時にObservableが使用するスケジューラーを指定します。
7	TimeInterval Observableを変換して、放出間の経過時間の表示を放出します。
8	Timeout アイテムを発行せずに指定された時間が発生すると、エラー通知を発行します。
9	Timestamp 放出された各アイテムにタイムスタンプを添付します。
9	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);
   }
}