Android中如何在ViewModel中重新执行StateFlow？实现数据刷新

你的代码无法实现计数器重启的核心原因是：count 这个 StateFlow 基于仓库中固定的无限流创建，调用 count.launchIn(this) 只是新增一个订阅者，并不会让原有的流重新开始计数。

要实现流的重启（比如重新发起API请求、重置计数器），可以通过触发源控制流的重建，具体修改如下：

修改后的 ViewModel 代码 #

class CounterViewModel(
    private val counterRepository: CounterRepository = CounterRepository(),
) : ViewModel() {
    // 用触发信号控制流的重建
    private val restartTrigger = MutableStateFlow(Unit)

    val count: StateFlow<Int> = restartTrigger
        // 触发信号更新时，取消旧流并订阅新流
        .flatMapLatest {
            counterRepository.getCountStream()
        }
        .stateIn(
            scope = viewModelScope,
            started = SharingStarted.WhileSubscribed(5_000L),
            initialValue = 0
        )

    fun restartCounter() {
        // 更新触发信号，触发流的重建
        restartTrigger.value = Unit
    }
}

原理说明 #

1. restartTrigger 作为重启动作的触发开关，每次调用 restartCounter 时更新它的值。
2. flatMapLatest 操作符会在触发信号更新时，立即取消之前订阅的流，并重新订阅新的 getCountStream() 流，从而实现计数器的重置重启。
3. 该逻辑同样适用于实际业务中的API请求场景：只需将 getCountStream() 替换为API请求的流，就能实现每次调用重启方法时重新发起请求。

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