使用 Flow、StateFlow、SharedFlow 发布价值时避免重复启动

Question

我正在从 LiveData 迁移到协程流，特别是 StateFlow 和 SharedFlow。不幸的是，发出值应该在 CoroutineScope 上运行，因此在 ViewModel 中使用它时，您会遇到丑陋的重复代码 viewModelScope.launch 。是否有一种最佳的方式来释放价值？

class MainSharedViewModel : BaseViewModel() {

    private val mainActivityState = MutableSharedFlow<MainActivityState>()

    fun getMainActivityState(): SharedFlow<MainActivityState> = mainActivityState

    fun setTitle(title: String){
        viewModelScope.launch {
            mainActivityState.emit(ToolbarTitleState(title))
        }
    }

    fun filterData(assetName: String){
        viewModelScope.launch {
            mainActivityState.emit(AssetFilterState(assetName))
        }
    }

    fun limitData(limit: Int){
        viewModelScope.launch {
            mainActivityState.emit(AssetLimitState(limit))
        }
    }

}

Answer 1

使用 tryEmit() 而不是 emit()。 tryEmit() 是非挂起的。它“尝试”的原因是，如果流的缓冲区当前已满并设置为 SUSPEND，则它不会发出，而不是在满时丢弃值。

请注意，您当前没有缓冲区，因为您将 replay 保留为 0。您应该将重播保持至少 1，这样当配置发生更改时就不会丢失值您的活动/片段。

示例：

fun setTitle(title: String){
    mainActivityState.tryEmit(ToolbarTitleState(title))
}

或者，您可以使用 MutableStateFlow，它的重播始终为 1，并且可以使用 value = 设置其值，就像 LiveData 一样。