kotlin - 流和 channel 流有什么区别？

Question

我在下面有两个代码，结果对我来说看起来一样

val namesFlow = flow {
    println("Start flow")
    (0..10).forEach {
        // Emit items with 500 milliseconds delay
        delay(500)
        println("Emitting $it")
        emit(it)
    }
}.map { it * it }

fun main() = runBlocking {
    namesFlow.collect { println(it) }
    namesFlow.collect { println(it) }
    println("Finish Flow")
}

和

val namesFlow = channelFlow {
    println("Start flow")
    (0..10).forEach {
        // Emit items with 500 milliseconds delay
        delay(500)
        println("Emitting $it")
        send(it)
    }
}.map { it * it }

fun main() = runBlocking {
    namesFlow.collect { println(it) }
    namesFlow.collect { println(it) }
    println("Finish Flow")
}

flow 和有什么区别和 channelFlow ?

Answer 1

channelFlow的目的|能够从同时运行的协程中检索结果。这是它的 documentation 中的一个示例通过同时收集当前流和另一个流来将另一个流合并到当前流中，将所有数据发送到同一个 channel :

fun <T> Flow<T>.merge(other: Flow<T>): Flow<T> = channelFlow {
    launch {
        collect { send(it) }
    }
    other.collect { send(it) }
}

由于您的代码没有使用调用 send 的功能从并发协程(你不能用 emit 做的事情)，你问题中的两个例子都有相同的行为。