gpt4 book ai didi

android - 如何将超过 2 个 api 调用的结果与 Coroutines Flow 结合起来?

转载 作者:行者123 更新时间:2023-12-02 13:16:19 26 4
gpt4 key购买 nike

zipcombine如果我没有遗漏任何内容,则只能组合 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 来处理并行请求?
我查看了 answer here但它返回编译错误,并且似乎没有公开的以列表为参数的流组合函数。

最佳答案


val f1 = flow {
emit(listOf(1, 2))
}

val f2 = flow {
emit(listOf(3, 4))
}

val f3 = flow {
emit(listOf(5, 6))
}

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 fA: Flow<A> = ...
val fB: Flow<B> = ...

suspend fun main() {
val fCombined = combine(fA, fB) { a: A, b: B ->
...
}
}
https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/combine.html

关于android - 如何将超过 2 个 api 调用的结果与 Coroutines Flow 结合起来?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63954308/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com