为何在Flow A中收集Flow B会导致Flow A的collect块重复调用？

首先明确几个关键概念和代码执行逻辑：

1. Flow的冷流特性 #

你定义的flowA和flowB都是冷流：冷流不会主动发射元素，只有当调用collect()、firstOrNull()这类终端操作时，才会从头开始执行发射逻辑。

2. flowA.collect的执行逻辑 #

flowA.collect { ... }的作用是订阅flowA，每当flowA发射一个元素，大括号里的lambda代码块就会被执行一次。具体流程：

• flowA发射第一个元素1时，lambda块（第2行的代码块）执行：打印1，然后调用flowB.firstOrNull()。
• flowA发射第二个元素2时，lambda块再次执行：打印2，再调用flowB.firstOrNull()。
• 以此类推，直到flowA的所有元素处理完毕。

你感知到的“collect块被再次调用”，本质是lambda块被每个元素依次触发执行，并非整个collect操作重新启动。

3. flowB.firstOrNull()的行为 #

firstOrNull()是Flow的终端操作，每次调用都会触发flowB从头开始发射元素，取到第一个元素后就停止。所以每次调用flowB.firstOrNull()，flowB都会重新发射6，因此每次打印的都是6。

总结 #

你的代码执行完全符合Flow的设计逻辑：

1. lifecycleScope.launch启动协程。
2. 订阅flowA，开始逐个发射元素。
3. 每个元素触发一次lambda块，先打印元素值，再触发flowB取第一个元素并打印。
4. 直到flowA所有元素处理完成。

输出1 6 2 6 3 6 4 6 5 6是完全正常的结果。

内容的提问来源于stack exchange，提问作者Lokik Soni