合并Kotlin流 [英] Merging kotlin flows

问题描述

给定2个或多个相同类型的流，是否有现有的Kotlin协程函数来合并它们，如RX合并运算符？

目前我正在考虑：

fun <T> merge(vararg flows: Flow<T>): Flow<T> = channelFlow {
    val flowJobs = flows.map { flow ->
        GlobalScope.launch { flow.collect { send(it) } }
    }
    flowJobs.joinAll()
}

但看起来有点笨拙。

推荐答案

我还不太熟悉流，因此这可能是次优的。无论如何，我认为您可以创建一个包含所有输入流的流，然后使用flattenMerge将它们再次扁平化为单个流。大概是这样的：

fun <T> merge(vararg flows: Flow<T>): Flow<T> = flowOf(*flows).flattenMerge()

编辑：

merge-函数是在1.3.3版本中添加到kotlinx-coroutine中的。查看此处：https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/merge.html

这篇关于合并Kotlin流的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！