2
У меня есть поток, который испускает элементы с момента создания элемента. Я знаю, какой элемент. После того как этот элемент будет включен, поток больше не выделяется. Проблема в том, что он не выпускает onComplete. Мне нужно что-то более менее похожее на takeWhile, но и на последний элемент. Это идея с мраморов:Как освободить последний элемент ussing takeWhile?
(Исходное изображение извлекается из ReactiveX TakeWhile)
Какой оператор или операторы могут использовать для этого?
Вы имеете в виду это: http://reactivex.io/RxJava/javadoc/rx/ Observable.html # takeUntil (rx.functions.Func1) – akarnokd
Да, спасибо! Я видел этого оператора на [его странице ReactiveX] (http://reactivex.io/documentation/operators/takeuntil.html), но как только я увидел два потока в основной реализации, я закрыл его. –