kotlin - 合并Kotlin流

Question

给定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()
}

但看起来有些笨拙。

Answer 1

我对流程还不太熟悉，所以这可能不是最理想的。无论如何，我认为您可以创建所有输入流的流，然后使用flattenMerge将它们再次展平为单个流。像这样的东西:

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

编辑:
在1.3.3版本中，merge -function已添加到kotlinx-协程。看到这里:https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/merge.html