RxJava Собирать эмиссию в список

Question

Как я могу собрать испущенные элементы из наблюдаемого в Список, когда наблюдаемое никогда не завершается?

Пример У меня есть нечто похожее, поэтому Наблюдаемое излучает ряд значений, но никогда не завершается, если вы не отмените подписку, потому что .toList() нетсработает.

Observable<User>
 .flatMap {}
 .toList()

Как я могу собрать всех пользователей в список и отправить его один раз после применения к нему функции flatMap?

Answer 1

Здесь есть несколько вариантов. Если вы хотите собирать их периодически, вы можете использовать buffer(). Или, если у вас есть другой сигнал для сбора, вы можете использовать where().