如何在Activity中不通过观察者获取ViewModel viewModelScope.launch的值？

核心问题 #

1. 协程异步执行导致值未更新：调用viewModelScopeCollectFlow()后立刻打印StateFlow的值，此时协程内的collect逻辑还未执行完毕，StateFlow仍保留初始默认值-1。
2. 串行collect阻塞后续逻辑：collect是挂起函数，第一个mFlowWithReturnAndDispatcher.collect会一直持有协程执行权（即便对应Flow只发射一次数据），导致后续的flowValue.collect永远不会执行，_mFlowValue永远无法被赋值为30。

修复步骤 #

1. 修正ViewModel的协程逻辑

将两个Flow的收集操作改为并发执行，避免串行阻塞：

fun viewModelScopeCollectFlow() {
    viewModelScope.launch {
        // 并发处理两个Flow的收集
        launch {
            getFlowWithReturnAndDispatcher().collect { value ->
                _flowWithReturnAndDispatcher.value = value
            }
        }
        launch {
            flowValue.collect { value ->
                _mFlowValue.value = value
            }
        }
    }
}

2. Java Activity中获取最新值的可行方案

由于Java不原生支持协程，在不使用观察者的前提下获取更新后的值，可采用以下两种方案：

方案一：将StateFlow转为LiveData（兼容Java）

在ViewModel中为StateFlow添加LiveData包装层：

// ViewModel内新增代码
val flowWithReturnAndDispatcherLiveData = flowWithReturnAndDispatcher.asLiveData()
val mFlowValueLiveData = mFlowValue.asLiveData()

在Java Activity中，可通过LiveData的getValue()获取当前值（需确保协程已执行完毕，可通过延迟或观察者确认值更新）：

// 示例：通过延迟等待协程执行完成（实际项目建议用LiveData观察者确认值更新后再获取）
new Handler(Looper.getMainLooper()).postDelayed(() -> {
    Timber.d("onCreate-> flowWithReturnAndDispatcher: " +
            viewModel.getFlowWithReturnAndDispatcherLiveData().getValue() + "" +
            "\nflowValue: " + viewModel.getMFlowValueLiveData().getValue());
}, 100);

方案二：ViewModel提供回调接口通知值更新

在ViewModel中定义回调接口，当两个Flow的值都更新后通知Activity：

// ViewModel内新增代码
interface OnDataLoadedListener {
    fun onDataLoaded(value1: Int?, value2: Int?)
}

private var dataLoadedListener: OnDataLoadedListener? = null

fun setOnDataLoadedListener(listener: OnDataLoadedListener?) {
    this.dataLoadedListener = listener
}

private fun checkAndNotify() {
    val val1 = _flowWithReturnAndDispatcher.value
    val val2 = _mFlowValue.value
    if (val1 != -1 && val2 != -1) {
        dataLoadedListener?.onDataLoaded(val1, val2)
    }
}

// 修改后的viewModelScopeCollectFlow
fun viewModelScopeCollectFlow() {
    viewModelScope.launch {
        launch {
            getFlowWithReturnAndDispatcher().collect {
                _flowWithReturnAndDispatcher.value = it
                checkAndNotify()
            }
        }
        launch {
            flowValue.collect {
                _mFlowValue.value = it
                checkAndNotify()
            }
        }
    }
}

在Java Activity中实现回调：

viewModel.setOnDataLoadedListener((value1, value2) -> {
    Timber.d("onDataLoaded-> flowWithReturnAndDispatcher: " + value1 + "\nflowValue: " + value2);
});
viewModel.viewModelScopeCollectFlow();

额外说明 #

• 不建议在Java中直接同步获取StateFlow的值，协程异步特性会导致大概率拿到未更新的默认值；若必须同步获取，需用CountDownLatch等工具阻塞等待协程完成，但会阻塞主线程，不推荐在UI场景使用。
• 最低SDK19可正常使用LiveData与StateFlow的转换逻辑，无兼容性问题。

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