Самый простой способ получить самый последний элемент работающего RxJava (1.x) Observable (блокирование)

Question

Как я могу получить самый последний элемент из активного Observable, не дожидаясь его завершения?Я понимаю, что это должен быть метод блокировки, и это нормально.Все, что я могу найти, это mostRecent() и next(), но они возвращают Iterables вместо реальных элементов.Мне не ясно, какова семантика итераций здесь.Я просто хочу получить элемент.Почему это так сложно?

Answer 1

Вы можете использовать оператор doOnNext() для выполнения операции с выданным значением.Например:

AtomicReference<Integer> sample = new AtomicReference<>();

...
.doOnNext( value -> sample.set( value ) )
...

Таким образом, value будет иметь самое последнее значение, которое было отправлено.