Wiederholen Sie das Senden von Objekt an Subsriber auf Rx

Question

ist es möglich, das gleiche Objekt wiederholt an Abonnenten in Rx zu senden? Für exmaple diesen Code (auf Kotlin):

val exmp = listOf("А") 
     var observable = exmp.toObservable() 
      observable.subscribeBy(
        onNext = { 
         it + "1" 
         println(it) 
        }, 
        onError = { it.printStackTrace() }, 
        onComplete = { println("Done!") } 
      ) 

Ich versuche String-Wert "A" wiederholt Methode OnNext() und get "A111111" zu senden. Methode Replay() der Rx-Bibliothek, wie ich verstehe, Startdatum für neue Subsribers wieder zu starten. Im Kreis for Datum von Observable nicht ändern, nur Methode wird mehrmals aufgerufen

Answer 1

Sie können versuchen, Ihre Observable ein ConnecableObservable tun observable.publish(); Auf diese Weise erhalten alle Abonnenten die gleichen Informationen und das Objekt wird nur einmal erstellt. https://github.com/ReactiveX/RxJava/wiki/Connectable-Observable-Operators