Rxjava-utility-operators

RxJava-ユーティリティオペレーター

以下は、Observableで役立つことが多い演算子です。

Sr.No.	Operator & Description
1	Delay Observableライフサイクルイベントを処理するアクションを登録します。
2	Materialize/Dematerialize 発行されたアイテムと送信された通知を表します。
3	ObserveOn 監視するスケジューラを指定します。
4	Serialize Observableが強制的にシリアル化された呼び出しを行うようにします。
5	Subscribe Observableからcompleteなどのアイテムと通知の放出を操作します
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);
   }
}

結果を確認する

次のように javac コンパイラを使用してクラスをコンパイルします-

C:\RxJava>javac ObservableTester.java

今ObservableTesterを次のように実行します-

C:\RxJava>java ObservableTester

それは次の出力を生成する必要があります-

abcdefg