StateFlow多收集器仅触发其一，如何通知所有ViewModel用户封禁事件

问题原因 #

1. StateFlow特性限制：StateFlow是有状态流，仅当值发生变化时才会发射新事件。如果设置true后未重置为false，后续再次设置true时，由于值未改变，不会触发新的发射——只有最先订阅的ViewModel能收到第一次的true，后续创建的ViewModel仅在订阅时获取当前的true，但无法接收后续的重复触发。
2. UserState实例非单例：如果每个ViewModel对应的UserState是不同实例，那么只有对应实例的ViewModel能收到通知，必须确保UserState是全局单例。

解决方案 #

1. 确保UserState是全局单例 #

保证所有Repository和ViewModel使用同一个UserState实例，比如通过依赖注入（如Hilt的@Singleton）或手动实现单例模式：

// 示例：手动实现单例
object UserState {
    private val _refetchAllLists: MutableStateFlow<Boolean> = MutableStateFlow(false)
    val refetchAllLists: StateFlow<Boolean> = _refetchAllLists

    fun setRefetchAllLists(bool: Boolean) {
        _refetchAllLists.value = bool
    }
}

2. 处理StateFlow的重复触发问题 #

方案A：触发后重置状态

在ViewModel处理完封禁事件后，将StateFlow的值重置为false，确保下次触发时值会变化：

• 修改UserState，添加重置方法：

private val _refetchAllLists: MutableStateFlow<Boolean> = MutableStateFlow(false)
val refetchAllLists: StateFlow<Boolean> = _refetchAllLists

fun triggerRefetch() {
    _refetchAllLists.value = true
}

fun resetRefetch() {
    _refetchAllLists.value = false
}

• ViewModel中处理完事件后重置：

init {
    viewModelScope.launch {
        repository.refetchAllLists().collect {
            if (it) {
                // 执行用户封禁后的逻辑
                repository.resetRefetch() // 处理完成后重置状态
            }
        }
    }
}

方案B：改用SharedFlow

SharedFlow支持发射重复值，无需依赖状态变化，更适合一次性事件通知：

• 修改UserState为SharedFlow：

private val _refetchAllLists = MutableSharedFlow<Boolean>(replay = 0)
val refetchAllLists: SharedFlow<Boolean> = _refetchAllLists

suspend fun triggerRefetch() {
    _refetchAllLists.emit(true)
}

• Repository中返回SharedFlow：

override fun refetchAllLists(): SharedFlow<Boolean> {
    return userState.refetchAllLists
}

• ViewModel中收集：

init {
    viewModelScope.launch {
        repository.refetchAllLists().collect {
            // 执行用户封禁后的逻辑
        }
    }
}

注：replay = 0表示新订阅者不会收到历史事件；若需要新创建的ViewModel能获取最近一次的触发事件，可将replay设为1。

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