RxJava параллельно излучать один раз - PullRequest
Новая
       5

RxJava параллельно излучать один раз

0 голосов
/ 11 ноября 2018

я пытаюсь получить массив потоковых данных, выполняемых параллельно с FlowableFromArray

и испускаем FlowableFromArray, когда все текущие таблицы сделаны.

Но мне не хватает метода для генерации в последний / последний.

Мне удалось заставить его работать только на следующем @ см ниже 

    val results = FlowableFromArray(flowableArray).parallel()
            .runOn(Schedulers.io())
            .sequential()
            .zipWith(r, BiFunction { t1: Flowable<String>, t2: Int
                ->
                t1
                        .subscribeOn(Schedulers.io())
                        .map { i -> parseYoutubeTrack(i) }
                        .observeOn(AndroidSchedulers.mainThread())
                        .subscribe { next -> TLog.i(TAG, "_NEXT_ ${next.videoId}") }

            })
            .subscribe()
...