0

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

4

1 に答える 1