kotlin - FlatMapMerge、FlatMapConcat 和 FlatMapLatest 之间有什么区别？

Question

我无法区分这三个运算符之间的确切区别。
文档:

FlatMapMerge

FlatMapConcat

FlatMapLatest

这些文档链接表明两个 Flow 被平面映射到一个 Flow 对象中。我对此没有意见，但我很难理解这三个运营商之间的排放量将如何变化。

Answer 1

我浏览了源代码，找到了一个明智的指南，但我没有通过谷歌搜索找到。 https://kotlinlang.org/docs/reference/coroutines/flow.html#flattening-flows
该指南解释了差异，但对我来说仍然有点不清楚，所以我在这里用我自己的话重写了它。
三者之间的基本区别取决于内部和外部流动对来自任一流动的新排放的 react 方式。所以对于给定的代码:

val outerFlow: Flow<>
val flatMappedFlow = outerflow
        .flatMapXXXXX { innerFlow(it) }
        .collect { processFlatMapResult(it) }

FlatMapConcat
此运算符是连续的和成对的。一旦outerFlow 发出一次，innerFlow 必须在收集最终结果之前发出一次。一旦任一流发出第 N 次，另一个流必须在收集第 N 个 flatMapResult 之前发出第 N 次。
FlatMapMerge
该运营商对排放的限制最少，但可能导致排放过多。每次outerFlow 发射一个值时，每个innerFlow 发射都会从该值flatMapped 到要收集的最终flatMapResult。最终的排放计数是innerFlow 和outerFlow 排放的乘积。
平面图最新
该算子只关心最新的排放结果，不处理旧排放。每次outerFlow 发出一个值时，它都会使用最新的innerFlow 值进行flatMapped。每次innerFlow 发出一个值时，它都会使用最新的outerFlow 值进行flatMapped。因此，最终的排放计数是介于零和内流排放乘以外流排放之间的值。