在具有两个StateFlow观察器的生命周期范围中,只有第一个有效



在我看来,我似乎不太明白什么。你能解释一下为什么当我使用这个例子时,只有第一次收集对我有效吗?

lifecycleScope.launch {
viewModel.test1.flowWithLifecycle(lifecycle, Lifecycle.State.STARTED).collect {
Log.i("Log_tag", it)
}
viewModel.test2.flowWithLifecycle(lifecycle, Lifecycle.State.STARTED).collect {
Log.i("Log_tag", it)
}
}

或者如果我这样称呼他们:

lifecycleScope.launch {
viewLifecycleOwner.lifecycle.repeatOnLifecycle(Lifecycle.State.STARTED){
viewModel.test1.collect {
Log.i("Log_tag", it)
}
viewModel.test2.collect {
Log.i("Log_tag", it)
}
}
}

但如果我在不同的协同程序中调用它们,那么它们两者都有效,如下所示:

lifecycleScope.launch {
viewModel.test1.flowWithLifecycle(lifecycle, Lifecycle.State.STARTED).collect {
Log.i("Log_tag", it)
}
}
lifecycleScope.launch {
viewModel.test2.flowWithLifecycle(lifecycle, Lifecycle.State.STARTED).collect {
Log.i("Log_tag", it)
}
}

视图模型:

class ForecastViewModel : ViewModel() {
private val _test1 = MutableStateFlow("")
private val _test2 = MutableStateFlow("")
val test1 = _test1.asStateFlow()
val test2 = _test2.asStateFlow()
fun getTest() {
viewModelScope.launch {
_test1.value = "test1"
_test2.value = "test2"
}
}

收集StateFlow永远不会完成,因为StateFlow不会终止。

这是意料之中的事。启动并发收集器是正确的做法。

(我想知道他们是否可以"重写"StateFlow.collect,使其返回类型为Nothing,以使其更清楚。(

最新更新