Kotlin flow 全面解析：从基础到高级

一个典型的 flow 包含哪些部分？

这是一个非常简单的问题，但是也最为我们所忽略。我们来看一个典型的 flow：

val flowA = flowOf(1, 2, 3) .map { it + 1 }

flow.collect { value ->
    println("Received $value")
}

由上面的代码我们可以看到一个 flow，一般包含三个部分构造符，collector，还有操作符（可选）。

一个 flow 通常来说会经历过哪些过程？

这个问题可以看作是对上个问题的补充，考察的是对 kotlin flow 的基础理解。
android 官方文档详细介绍了每个流程。具体流程为

1. 创建数据流
2. 修改数据流
3. 收集数据流
4. 捕获数据流异常
5. 在不同 Coroutine​Context 中运行

希望大家都能牢记这些流程，他对我们后续其他问题的理解会有帮助。

一个 flow 可以有多少个 collector？

kotlin 本身并没有对 collector 数量进行限制，每个 collector 都会收到同样的数据。

flow 到底是热的还是冷的？

默认使用 builder 构造出来的 flow 是冷的，而 StateFlow，SharedFlow 是热的。

冷流热流的区别

冷流 (Cold Flow):

• 惰性 (Lazy):  按需执行。
• 单播 (Unicast) per collection:  每个收集器获得独立的执行和数据。
• 生产者为每个收集器重新执行。

热流 (Hot Flow):

• 主动 (Active):  可能在没有收集器的情况下就发射数据。
• 多播 (Multicast) / 广播 (Broadcast):  多个收集器共享来自同一生产者的数据。
• 生产者通常只执行一次（或独立于收集器执行）。
• 新收集器可能错过早期数据，除非 Flow 配置了重播 (replay) 机制。

那么 cold flow 与 hot flow 的 collect 执行起来有什么区别吗？

val stateFlow = MutableStateFlow("初始值")

launch { stateFlow.collect { println("收集器1: $it") } }
launch { stateFlow.collect { println("收集器2: $it") } }
launch { stateFlow.collect { println("收集器3: $it") } }
delay(10)
stateFlow.emit("修改后的值")

val flowNormal = flowOf(1,2,3)
launch {
    flowNormal.collect {
        println("flowNormal collector1 $it")

    }
}

launch {
    flowNormal.collect {
        println("flowNormal collector2: $it")
    }
}

看下上面代码，猜一猜会输出什么？

好了，展示一下执行结果，是不是有些奇怪，cold flow 每次收集都是独立的，这也是冷流热流的主要区别之一。

热流与冷流 collect 是否阻塞后续代码执行？

相信很多好奇的宝宝已经看到上面的代码都运行在独立的 coroutineScope 之中了，你可能会问 我如果去掉 scope 让他们运行在同一个 coroutineScope 可以不可以呢？下面我们改下代码，咱们看看情况。

stateFlow.collect { println("收集器1: $it") } 
stateFlow.collect { println("收集器2: $it") }
delay(10)
stateFlow.emit("修改后的值")

猜一下输出结果会是怎样？结果可能让很多人大吃一惊。

我们可以看到 stateFlow.collect { println("收集器1: $it") } 这行代码执行完之后，阻塞了后续的代码执行，也就是说当前 flow 挂起在这里了，当然如果感兴趣的同学可以看看源码实现。最后这个规则一定要记住，热流需要放在单独的 scope 之中运行，不然会阻塞后续的任务执行，我曾经就写过一个相关的 bug, 我在 viewmodel scope 里面执行了两个 collect 但是第二个并没有正确执行。