TL; DR
Как преобразовать Task.whenAll(List<Task>)
в RxJava
?
В моем существующем коде используются болты для создания списка асинхронных задач и ожидания до завершения всех этих задач перед выполнением других действий. По существу, он создает List<Task>
и возвращает один Task
, который помечен как завершенный, когда все задачи в списке завершены, в соответствии с примером на Болты.
Я хочу заменить Bolts
на RxJava
, и я предполагаю, что этот метод создания списка задач async (размер неизвестен заранее) и завершение их всех в один Observable
возможен, но я не знаю, как это сделать.
Я пробовал смотреть merge
, zip
, concat
и т.д.... но не могу работать над List<Observable>
, который я бы наращивал, поскольку все они, похоже, ориентированы на работу всего за два Observables
за раз, если я правильно понимаю документы.
Я пытаюсь узнать RxJava
и все еще очень новичок в этом, так что простите меня, если это очевидный вопрос или объясняется в документах где-то; Я попробовал поиск. Любая помощь будет высоко оценена.