Intereting Posts
Kapt не работает с AutoValue в Android Studio 3.0 Ошибка комнаты в Android: TypeConverter не распознается для списка перечислений Типы и обобщения платформ Kotlin Почему я получаю android.os.TransactionTooLargeException в своем приложении для Android, написанном в Kotlin / rxJava, когда я выхожу из приложения? (OnExit / OnPause)? Использование Glide для кэширования изображений веб-просмотра Как преобразовать метод класса <T> #cast из Java в Kotlin? Устранение неполадок при настройке изображения для выбранного объекта Image Image Kotlin / Anko DSL Ввод общей лямбды в карту Eclipse Aether не разрешает `LATEST` правильно Получение данных из файла JSON Матч скобки kotlin способ kotlin, которая может использовать соединение httpS без проверки сертификата (например, curl – insecure) Android Studio 3.0 не может предложить импорт для shl и shr в Kotlin Контекстная проблема при использовании Anko DSL в настраиваемом адаптере для ListView Почему IntelliJ Idea не признает мои тесты Spek?

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

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

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

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

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

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

Solutions Collecting From Web of "Как собрать асинхронный ответ с помощью RxJava"

Наконец, я выполнил, используя 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() }