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
日付が変わらず、メソッドだけが数回呼び出されます