можно ли повторно отправлять один и тот же объект подписчикам в Rx? Например, этот код (на Котлине):
val exmp = listOf("А")
var observable = exmp.toObservable()
observable.subscribeBy(
onNext = {
it + "1"
println(it)
},
onError = { it.printStackTrace() },
onComplete = { println("Done!") }
)
Я пытаюсь повторно отправить строковое значение «A» методу onNext() и получить «A111111». Метод replay() библиотеки Rx, как я понимаю, снова начинает отправку даты для новых подписчиков. В круге for
дата из observable не меняется, просто метод вызывается несколько раз