如何合并到 kotlin 协程？

Question

我有 2 个流程想要合并，就像我以前在 Rx 中所做的那样Java。

在 Rx-Java:

Flowable.just(1).mergeWith(Flowable.just(2)).subscribe({ println(it)}) // result: 1, 2

如何在 Kotlin 协程中复制它？提前致谢。

Answer 1

flattenMerge 应该提供相同的行为。例如，

    val flow1 = (1..3).asFlow()
    val flow2 = (4..6).asFlow()
    flowOf(flow1, flow2).flattenMerge().collect { value ->
        println("$value")
    }