RxJava:单打列表

Lau*_*der 1 kotlin rx-java rx-java2

我在使用 RxJava 时遇到了一些麻烦。我正在使用 Kotlin 编码。这是我的问题:
我有一份单身人士名单。现在我需要所有 Singles 的发出结果才能继续。如果单打比赛能够并行进行并且结果保持相同的顺序,那就太好了。当所有单身人士都公布了他们的结果时,我想继续。

val list_of_singles = mutableListOf<Single<Type>>()
val results: List<ResultType> = runSingles(list_of_singles)
// use results here...
Run Code Online (Sandbox Code Playgroud)

如果您需要更多信息,请与我们联系。

谢谢!!!:)

Dav*_*son 6

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))
}
Run Code Online (Sandbox Code Playgroud)