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

結果を確認する

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

C:\RxJava>javac ObservableTester.java

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

C:\RxJava>java ObservableTester

次の出力が生成されます-

abcdefg