Intereting Posts
Фильтр для общего типа без отражения или литья Как акцептор может добавить значение в состояние и отправить обратно инициатору Ошибка Null Pointer в ссылке RecyclerView в фрагменте с использованием Kotlin Недвижимость без геттера в Котлине Как запустить другой файл .kt / Class в той же папке src? Не удается разрешить строку, переданную параметру vararg в функции расширения ojAlgo – Выражение переменных как границ в оптимизации? Должен ли возврат DAO от Kotlin Необязательный или нулевой? Представления не отображаются в ViewPager format @Query параметр – Дооснащение 2 Инициализация массивов в котлине Kotlin lazy свойство в зависимости от другого свойства, инициализированного в init Строительство проектов Kotlin с Gradle иногда не получается с NoClassDefFoundError Не выходите из программы Kotlin, пока выполняется несколько сопрограмм Что заставляет HtmlUnit загружать страницу магазина PSN?

Как собрать асинхронный ответ с помощью 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() }