RxJava-연결 가능한 연산자

다음은 구독을보다 정확하게 제어하는 운영자입니다.

Sr. 아니.	연산자 및 설명
1	Connect 구독자에게 항목을 내보내도록 연결 가능한 Observable에 지시하십시오.
2	Publish Observable을 연결 가능한 Observable로 변환합니다.
삼	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);
   }
}