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)
如果您需要更多信息,请与我们联系。
谢谢!!!:)
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)
| 归档时间: |
|
| 查看次数: |
3078 次 |
| 最近记录: |