重复发送对象到Rx上的子客户端

是否可以将相同的对象反复发送给Rx中的订阅者？ 例如，这个代码（在Kotlin上）：

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

我尝试将字符串值“A”重复发送到方法onNext（）并获得“A111111”。 Rx库的方法重放（）我明白开始发送日期再次为新的潜艇。 在从可观察的日期开始不变的循环for ，只是方法被调用几次

Answer 1

你可以试着让你可观察的一个ConnectableObservable做observable.publish（）; 通过这种方式，所有用户将获得相同的信息，对象也将被创建一次。 https://github.com/ReactiveX/RxJava/wiki/Connectable-Observable-Operators