Как я могу накапливать каждые 2 излучаемых значения Observable с Rx на Android?

Question

У меня есть одна наблюдаемая, которая выдает значения от 0 до 10 за каждую секунду. Мне нужно накапливать каждые два значения и выводить результат значения аккумулятора с завершением.

Answer 1

Вы можете использовать оператор reduce. Вот пример котлина:

Observable.just(1,2,3)
    .reduce { t1: Int, t2: Int -> t1+t2}
    .subscribe { print(it) } // prints only sum

Answer 2

Готово! Я использовал метод buffer (4), чтобы получить каждое из 4 значений в списке и сохранить первые два значения из него для накопления моего счетчика:)