Как собрать асинхронный ответ с помощью RxJava

Вот моя цель: собрать ответы от асинхронных задач, которые поступают из сторонней библиотеки

Требование: используйте RxJava2 для выполнения в порядке

Я застрял в мысли, что я использую оператора или операторов для этого, идеи приветствуются.

Моя мысль такова:

Flowable.fromIterable(list) .anOperatorCanOnNextTheResponse() .buffer() .subscribe(newList) 

Наконец, я выполнил, используя PublishProcessor, PublishSubject также может сделать трюк, но я пропущу разницу между ними.

 val mPublishProcessor: FlowableProcessor<String> = PublishProcessor.create<String>().toSerialized() list.forEach { doSomeAsyncTasksWithCallback(string) { mPublishProcessor.onNext(string) } } mPublishProcessor .buffer(list.size) .observeOn(AndroidSchedulers.mainThread()) .subscribe { doSomethingWithTheCollectedStrings() } 
Intereting Posts
Методы Java ошибочно автоматически перегружаются в котлин Как передать vararg в функцию или конструктор varag в Kotlin? Не выходите из программы Kotlin, пока выполняется несколько сопрограмм Почему кинжал не обрабатывает эти котлинские дженерики? Невозможно повторно назначить локальные переменные Получение NoClassDefFoundError при вызове функции расширения kotlin Круговая зависимость при компиляции с Kotlin 1.1.2-4, но не на 1.1.2-3 Когда выражение в котлине не работает должным образом Написание реагирует на родной модуль Android в Котлине? Почему AtomicInteger является абстрактным в Котлине? (он отлично работает на Java) Обратный экземпляр enum непосредственно без класса в Котлине Есть ли лучший способ получить доступ к свойствам с возможностью NULL? Котлин: проблемы с пониманием дженериков Есть ли официальный путеводитель по Kotlin? Классы класса Kotlin, которые наследуют классы Java, также наследуются от Any?