Rxjava-connectable-operators

RxJava-接続可能なオペレーター

以下は、サブスクリプションをより正確に制御できるオペレーターです。

Sr.No.	Operator & Description
1	Connect 接続可能なObservableに、サブスクライバーにアイテムを発行するように指示します。
2	Publish Observableを接続可能なObservableに変換します。
3	RefCount 接続可能なObservableを通常のObservableに変換します。
4	Replay Observableがアイテムの発行を開始し、サブスクライバーが後でサブスクライブした後でも、各サブスクライバーが同じ順序で発行されたアイテムを見るようにします。

接続可能なオペレーターの例

C：\> RxJavaなどで選択したエディターを使用して、次のJavaプログラムを作成します。

ObservableTester.java

import io.reactivex.Observable;
import io.reactivex.observables.ConnectableObservable;
//Using connect operator on a ConnectableObservable
public class ObservableTester {
   public static void main(String[] args) {
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      ConnectableObservable<String> connectable = Observable.fromArray(letters).publish();
      connectable.subscribe(letter -> result.append(letter));
      System.out.println(result.length());
      connectable.connect();
      System.out.println(result.length());
      System.out.println(result);
   }
}

結果を確認する

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

C:\RxJava>javac ObservableTester.java

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

C:\RxJava>java ObservableTester

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

0
7
abcdefg