Kotlin协程：多收集器场景下如何避免map()重复调用？

官方推荐实现方式 #

Kotlin协程库已提供现成操作符shareIn，可将普通Flow转换为共享Flow，让多个收集器共享上游执行结果，彻底避免重复执行map这类高开销操作。

使用示例：

fun main() {
    runBlocking {
        val sourceFlow = MutableSharedFlow<Int>()

        val mappedFlow = sourceFlow
            .map {
                println("INSIDE MAP")
                return@map it.toString()
            }
            .shareIn(this, SharingStarted.WhileSubscribed(), replay = 0)

        launch {
            mappedFlow.collect {
                println(it)
            }
        }

        launch {
            mappedFlow.collect {
                println(it)
            }
        }

        launch {
            delay(1000)
            sourceFlow.emit(1)
        }
    }
}

运行后INSIDE MAP仅输出一次，两个收集器都会收到转换后的结果，完全匹配需求。

shareIn核心参数说明：

• 第一个参数为协程作用域，用于控制共享Flow的生命周期
• SharingStarted.WhileSubscribed()：当存在活跃收集器时保持共享，无收集器时停止，适配绝大多数业务场景
• replay：设置重播历史值的数量，0表示不重播，可根据实际需求调整

你的flatten方案存在的问题 #

1. 生命周期管理缺失：在传入的作用域中启动协程收集上游Flow，但未处理上游异常或作用域取消场景，易导致协程泄漏、资源无法释放。
2. 背压支持不足：手动创建的MutableSharedFlow默认无背压策略配置，当上游发送速度快于收集器处理速度时，可能出现数据丢失或积压问题，而shareIn内部已完善处理背压逻辑。
3. 功能灵活性差：无历史值重播选项，也没有灵活的启动策略，若有新收集器订阅，无法获取之前发送的数据（若业务需要的话）。
4. 冗余实现：官方已提供成熟的shareIn操作符，重复造轮子无必要，还可能引入潜在Bug。

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