rx-java - 在 Rx 上重复向订阅者发送对象

Question

是否可以重复向 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 库的方法 replay() 再次开始为新订阅者发送日期。从可观察到的循环for日期没有变化，只是方法被调用了几次

Answer 1

你可以尝试让你的 observable 成为 ConnectableObservable 做 observable.publish(); 这样，所有订阅者都将获得相同的信息，并且对象也只会被创建一次。 https://github.com/ReactiveX/RxJava/wiki/Connectable-Observable-Operators