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

Question

使用zip 或combine，如果我没有遗漏任何内容，则只能合并两个流，我看不到任何组合流列表或vararg 的公共方法。

例如

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，但它返回编译错误，并且似乎没有公开的以列表为参数的流组合函数。

Answer 1

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