流和通道流有什么区别？

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是能够从并发运行的协程中检索结果。以下是其文档中的一个示例，通过同时收集当前流和另一个流，将所有数据发送到同一通道，将另一个流合并到当前流中：

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

由于您的代码没有使用从并发协程调用的功能send（您无法使用emit），因此问题中的两个示例具有相同的行为。