RxJava 连接操作符|极客教程

RxJava 连接操作符

以下是具有更精确订阅控制的操作符。

序号	运算符与描述
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);
   }
}