kotlin 如何使用协程流合并两个以上API调用的结果？

mfpqipee 于 2023-01-31 发布在 Kotlin

关注(0)|答案(1)|浏览(485)

使用zip或combine，如果我不错过任何东西，就只能合并2个流，我无法看到任何组合流列表或vararg的公共方法。
例如

apiHelper.getUsers()
            .zip(apiHelper.getMoreUsers()) { usersFromApi, moreUsersFromApi ->
                val allUsersFromApi = mutableListOf<ApiUser>()
                allUsersFromApi.addAll(usersFromApi)
                allUsersFromApi.addAll(moreUsersFromApi)
                return@zip allUsersFromApi
            }

我需要从REST API中获取前5个页面，并并行获取它们，然后合并结果，进行一些Map，并对组合数据进行过滤。我可以使用flow组合它们吗？或者我应该传递coroutineScope并使用异步来进行并行请求？
我 checkout 了answer here，但它返回了编译错误，并且似乎没有将list作为参数的flow的公共合并函数。

kotlin

来源：https://stackoverflow.com/questions/63954308/how-to-combine-results-of-more-than-2-api-calls-with-coroutines-flow

1条答案

按热度按时间

omqzjyyz1#

存在顶级combine函数

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> = ...
val fС: Flow<С> = ...

suspend fun main() {
    val fCombined = combine(fA, fB, fС) { a: A, b: B, c: C ->
        ...
    }
}

赞(0）回复(0）举报 2023-01-31

我来回答

kotlin 如何使用协程流合并两个以上API调用的结果？

1条答案

相关问题

热门标签

最新问答