Леди и джентльмены, всё сталкиваюсь и сталкиваюсь с одной и той же проблемой. Где-то в моём понимании самых главных вещей в RX что-то пошло принципиально неправильно и у меня постоянно возникает следующая ситуация:
Вот у меня есть источник данных. Пусть будет пуш в андройде. Я его эмичу из обзервабла. И мой кейс в том, что я хочу, чтобы источник данных "забыл" об заэмиченном айтеме в определённый момент. Я видел и использовал много решений и каждый раз это всё очень error-prone выходит. Пока что работает лучше всего прокидывание через BehaviorSubject энумчика с emptyState условным и обращению к нему не напрямую, а через метод, который это учитывает и в случае чего высылает Observable.empty()
Мой вопрос в том, как мне лучше обрабатывать ситуацию, где я хочу, чтобы заэмиченный айтем был "поглощаемым", т.е. после того, как я его условно "обработал" он пропадал из источника? Были лютые мысли сделать свой сабджект и свой субскрайб с блекджеком и шлюхами "поглощением" айтема после того, как отработал онНекст в подписчике, например.
Но мне кажется, опять-таки, что я как-то неправильно "реактивно" мыслю просто.
