Android ViewModel中Flow异常后保活/重启及异常场景疑问

1. 触发case2后如何重启Flow或防止其被取消 #

外层try-catch捕获的是**collect调用环节（包括collect的Lambda内部）抛出的未处理异常**，此时Flow确实会因未捕获异常被取消。要实现错误展示+Flow可重试/存活，有两种可行方案：

方案一：避免Flow被取消（在collect内部处理异常） #

如果异常出现在collect的UI更新逻辑里，直接在Lambda内部加try-catch消化异常，不让它传到外层，Flow就能保持存活：

.collect { data ->
    try {
        // UI状态更新逻辑
        uiState = uiState.copy(data = data)
    } catch(e: Exception) {
        Timber.e("UI更新出错")
        Timber.e(e)
        // 这里可更新UI展示错误提示，Flow会继续运行
    }
}

方案二：实现Flow重启（用触发信号重新收集） #

如果必须让外层捕获异常，或需要用户主动点击重试，可以把整个Flow收集逻辑包装成可触发任务，用MutableStateFlow作为重启信号：

private val retrySignal = MutableStateFlow(Unit)

init {
    viewModelScope.launch {
        // 监听重试信号，每次信号变化就重新收集Flow
        retrySignal.collect {
            try {
                myRepository
                    .getAllData()
                    .catch {
                        Timber.e("catch exception case 1")
                        Timber.e(it)
                    }
                    .collect { data ->
                        uiState = uiState.copy(data = data)
                    }
            } catch(e: Exception) {
                Timber.e("catch exception case 2")
                Timber.e(e)
                // 更新UI展示错误，比如弹出重试按钮
            }
        }
    }
}

// 用户点击重试按钮时调用该方法
fun retryLoadData() {
    retrySignal.value = Unit
}

每次调用retryLoadData()，就会重新触发一次Flow收集，相当于重启。

2. 什么场景会触发case1 #

catch操作符专门捕获它上游Flow环节中抛出的异常，也就是myRepository.getAllData()及其之前的Flow操作里出现的异常，常见场景包括：

• getAllData()内部的数据源操作出错（比如Room数据库查询异常、网络请求失败抛出异常）
• getAllData()返回的Flow在发射数据（emit）时抛出异常
• 上游Flow添加的其他操作符（比如map、filter）处理数据时抛出的异常

只要异常发生在catch操作符之前的Flow链路中，就会被这个catch捕获，进入case1逻辑。

内容的提问来源于stack exchange，提问作者me.at.coding