Я использую ReplaySubject вместо PublishSubject, потому что мне нужны предыдущие значения. Но иногда выходит какая-то ошибка(не знаю какая) и в ReplaySubject вызывается onError и он умирает. Есть какой то способ оставить его живим? Возможно, есть более удобный способ реализовать это логику.
https://github.com/JakeWharton/RxRelay Basically: A Subject except without the ability to call onComplete or onError.
Или retry()
Это первая rxjava? Может там ошибка backpressure? У subject есть onBackpressureBuffer метод, можно его заюзать, если такая ошибка возникает.
Обсуждают сегодня