RxJava:单曲列表

Question

我在RxJava方面遇到了一些问题。我正在和科特林一起编码。这是我的问题：
我有一个单身汉列表。现在，我需要所有Single的已发射结果才能继续。如果单打能够平行进行，结果保持不变，那就太好了。当所有Singles都发出结果时，我想继续。

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

如果你需要更多信息，请告诉我。

谢谢！！！：(

Answer 1

Single#zip怎么样？

fun main() {
val singles = listOf(
Single.just(1),
Single.just(2),
Single.just(3)
)
val list : Single<List<Int>> = Single.zip(singles) {
it.toList() as List<Int>
}

list.test().assertResult(listOf(1,2,3))
}

Answer 2

我是这样解决的：

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)

使用框架比反对框架更有意义