У меня есть кэш наблюдаемых и повторно их используюВсе они обычно используют какое-то кэширование (в основном replay(1).refCount()), и я уверен, что базовый расчет выполняется только один раз с этим.
У меня сейчас есть случаи, когда базовый поток генерирует элементы, и никто неподписался на мою кешированную наблюдаемую.Я все еще хочу, чтобы он обработал это событие.Как я могу это сделать?
В настоящее время я могу сделать это только следующим образом:
val o = observable.reply(1)
o.connect() // make sure this hot observable always is connected and processes it's input
return o // this one is cached
Есть ли какой-нибудь лучший способ?Я хочу, чтобы горячая наблюдаемая всегда действовала так, как будто кто-то подписан и никогда не отписывается от вышестоящих ...обрабатывать КАЖДЫЙ ввод, независимо от того, подписан ли кто-то или нет, чтобы кэшированные значения, которые воспроизводились, всегда были самыми новыми ...