Jetpack Compose中Composable收集Flow无响应问题

核心问题是Composable重组时反复创建新的Flow实例，导致收集流程被中断：

• 你在Composable中直接调用viewmodel.getStream()获取Flow，而getStream()每次调用都会构造一个全新的冷Flow。Composable在初次组合、后续任意重组触发时，都会重新执行这行代码，拿到新Flow后重新启动收集流程。
• 新Flow启动后，走到api.getStream()发起网络请求、读取SSE数据是异步耗时操作，还没等执行到try块内的emit，下一次重组就会再次创建新Flow替换掉当前正在执行的收集任务，自然永远收不到try块内抛出的数据。
• 你在try块外写的emit是Flow启动后同步执行的逻辑，在Flow创建的瞬间就能被收集到，所以只有这部分值能正常显示。
• 你在ViewModel内部收集能正常拿到数据，本质是因为你在ViewModel里只调用了一次getStream()，全程持有同一个Flow实例持续收集，没有被反复重建替换，所以能正常拿到SSE返回结果。

另外还有个隐藏问题：你没有给Flow指定IO调度器，网络请求默认会在收集Flow的主线程执行，本身就有触发ANR、阻塞UI线程的风险。

按照以下步骤调整即可解决问题：

1. 在ViewModel层缓存Flow实例，将冷流转成带生命周期感知的StateFlow，避免反复创建新Flow，同时把网络请求切到IO线程：

// ViewModel 内实现
private val eventStream = repository.getStream()
    .flowOn(Dispatchers.IO) // 将网络请求、SSE读取逻辑切到IO线程执行
    .stateIn(
        scope = viewModelScope,
        // 页面在后台5秒内再切回不会重新发起请求，兼顾性能和资源释放
        started = SharingStarted.WhileSubscribed(5000),
        initialValue = "Loading"
    )

fun getEventStream(): StateFlow<String> = eventStream

2. Composable层直接收集ViewModel中缓存好的StateFlow即可，不会再因为重组反复创建新Flow：

@Composable
fun FirstPage(
    viewmodel: MyViewModel = hiltViewModel()
) {
    val eventStream = viewmodel.getEventStream().collectAsState().value
    // 后续页面渲染逻辑直接使用eventStream即可
}

3. 额外校验Repository层的SSE读取逻辑：确保while(true)循环内的读取操作是挂起函数，不会死循环阻塞所在线程，否则会导致Flow无法正常调度执行emit。

不要在Composable的组合执行路径里直接调用会创建新Flow、发起网络请求这类带副作用的方法。这类逻辑要么放在ViewModel层转成热流缓存，要么用LaunchedEffect等副作用API包裹，确保重组时不会反复执行。

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