kotlin - RxJava:单例名单

Question

我在使用RxJava时遇到了一些麻烦。我正在用Kotlin编码。这是我的问题:
我有单打的 list 。现在，我需要所有单打发出的结果才能继续。
如果单打可以并行运行，并且结果保持相同顺序，那将是很好。
当所有单打发出结果时，我要继续。

val list_of_singles = mutableListOf<Single<Type>>()
val results: List<ResultType> = runSingles(list_of_singles)
// use results here...

如果您需要更多信息，请与我们联系。
谢谢!!! :)

Answer 1

我是这样解决的:

    val disposable = Observable.fromIterable(itemList).flatMapSingle { item ->
        getSingle(item)
            .map { singleResult ->
                // do something with single result
            }
    }.doOnComplete {
        // do stuff after processing all singles
    }.subscribe()

    addToCompositeDisposable(disposable)

使用该框架比不使用它更有意义。