使用zip
或combine
,如果我什么都没错过,则只能合并2个流,我将无法看到任何结合流或vararg
列表的公共(public)方法。
例如
apiHelper.getUsers()
.zip(apiHelper.getMoreUsers()) { usersFromApi, moreUsersFromApi ->
val allUsersFromApi = mutableListOf<ApiUser>()
allUsersFromApi.addAll(usersFromApi)
allUsersFromApi.addAll(moreUsersFromApi)
return@zip allUsersFromApi
}
我需要从REST api获得前5页,并以并行方式获取它们并合并结果,对映射的数据进行一些映射和过滤。我可以将它们与flow
结合使用,还是应该通过coroutineScope并使用async进行并行请求?我 checkout 了answer here,但它返回编译错误,并且似乎没有将列表作为参数的流的公共(public)合并功能。
最佳答案
suspend fun main() {
combine(f1, f2, f3) { elements: Array<List<Int>> ->
elements.flatMap { it }
}.collect {
println(it) // [1, 2, 3, 4, 5, 6]
}
combine(f1, f2, f3) { list, list2, list3 ->
list + list2 + list3
}.collect {
println(it) // [1, 2, 3, 4, 5, 6]
}
}
val f1 = flow {
emit(listOf(1, 2))
}
val f2 = flow {
emit(listOf(3, 4))
}
val f3 = flow {
emit(listOf(5, 6))
}
https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/combine.html