3

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

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？

4

1 回答 1

1

的目的channelFlow是能够从同时运行的协程中检索结果。这是其文档中的一个示例，该示例通过同时收集当前流和另一个流，将所有数据发送到同一通道，将另一个流合并到当前流中：

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

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

于 2020-08-14T06:46:06.503 回答