RxJava - Verbindbare Operatoren

Im Folgenden sind die Betreiber aufgeführt, die eine genauere Kontrolle über das Abonnement haben.

Sr.Nr.	Betreiber & Beschreibung
1	Connect Weisen Sie ein verbindbares Observable an, Elemente an seine Abonnenten zu senden.
2	Publish Konvertiert ein Observable in ein verbindbares Observable.
3	RefCount Konvertiert eine anschließbare Observable in eine normale Observable.
4	Replay Stellen Sie sicher, dass jeder Abonnent dieselbe Reihenfolge der ausgegebenen Elemente sieht, auch nachdem das Observable mit dem Senden von Elementen begonnen hat und die Abonnenten später abonnieren.

Beispiel für einen anschließbaren Bediener

Erstellen Sie das folgende Java-Programm mit einem beliebigen Editor Ihrer Wahl, z. B. in C: \> RxJava.

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