将RxJava转Kotlin Flow：是否存在用当前协程作用域的shareIn()？

问题描述 #

我正尝试将以下RxJava代码转换为Kotlin Flow：

fun fetchData(){
    val net = Observable.fromCallable {
            expensiveNetworkCall()
          }
          .share()
    
    val computeFlow0= net.map{ compute0(it) }
    val computeFlow = net.map{ compute(it) }
    return Observable.merge(computeFlow0, computeFlow)
}

我了解到Kotlin提供了shareIn()，它与RxJava的share()功能基本一致，但需要传入CoroutineScope。我可以为fetchData()添加CoroutineScope参数来适配shareIn()，但有没有更优的实现方式？是否存在可复用原Flow协程作用域的shareIn()版本？

解决方案 #

1. 场景化复用内置作用域（以Android为例） #

如果是在Android的ViewModel中实现，直接复用ViewModel自带的viewModelScope即可，无需额外传递作用域，这是最贴合业务场景的优化方式：

fun fetchData(): Flow<YourResultType> {
    val netFlow = flow {
        emit(expensiveNetworkCall())
    }.shareIn(
        scope = viewModelScope,
        started = SharingStarted.WhileSubscribed(5000), // 对齐RxJava share()的默认生命周期
        replay = 1
    )

    val computeFlow0 = netFlow.map { compute0(it) }
    val computeFlow = netFlow.map { compute(it) }

    return merge(computeFlow0, computeFlow)
}

其中SharingStarted.WhileSubscribed(5000)会在最后一个订阅者取消后延迟5秒停止上游流，和RxJavashare()的默认行为匹配；replay=1保证新订阅者能拿到最新的请求结果。

2. 让函数返回冷Flow，由调用方管理共享 #

如果不想把作用域耦合在fetchData()内部，可以让函数返回纯冷Flow，把shareIn的调用逻辑交给函数的使用者：

fun fetchData(): Flow<YourResultType> {
    val netFlow = flow {
        emit(expensiveNetworkCall())
    }

    val computeFlow0 = netFlow.map { compute0(it) }
    val computeFlow = netFlow.map { compute(it) }

    return merge(computeFlow0, computeFlow)
}

// 调用方处处理共享逻辑
val sharedDataFlow = fetchData().shareIn(
    scope = yourCoroutineScope,
    started = SharingStarted.WhileSubscribed(),
    replay = 1
)

这种方式灵活性更高，fetchData()只负责定义数据流的转换逻辑，完全由消费方决定共享策略和作用域。

3. 不存在“复用原Flow协程作用域”的shareIn版本 #

Kotlin Flow的核心设计是冷流：上游流的执行完全由订阅者的协程作用域驱动。而shareIn的作用是将冷流转换为热流，必须指定一个独立的作用域来维持热流的生命周期——否则当所有订阅者取消后，热流会立刻终止，无法实现RxJavashare()的多订阅共享效果。这是Flow的设计逻辑决定的，因此不存在无需传入作用域的shareIn变体。

内容的提问来源于stack exchange，提问作者Some Noob Student