2

在 MyViewModel 中，使用 MutableStateFlow 将事件传输到片段。当 MutableStateFlow 的值改变时，早期的值在协程内被覆盖。所以从来没有被片段收到。

internal class MyViewModel(application: Application) : AndroidViewModel(application) {
    private val myMutableStateFlow = MutableStateFlow<MySealedClass>(MySealedClass.Dummy1())
    private fun getData() {
        viewModelScope.launch {
            //yield()
            myMutableStateFlow.value = MySealedClass.Dummy2()
            myMutableStateFlow.value = MySealedClass.Dummy3()
        }
    }
}

internal class MyFragment : Fragment(){
    private var uiStateJob: Job? = null
    override fun onStart() {
        super.onStart()
        uiStateJob = lifecycleScope.launch {
           myViewModel.getUiFlow().collect {
              //do something
           }
       }
    }
}

如果对 yield() 进行了注释，则 Fragment 永远不会收到 Dummy2 事件。虽然收到了 Dummy 3。如果 yield() 未注释 Dummy2 和 3 都收到。如果状态值在协程之外发生了变化，那么 Dummy2 和 Dummy3 都会被接收。

我需要以可预见的方式接收片段中的所有事件。这种行为有适当的理由吗？

4

1 回答 1

3

StateFlow是为了代表一个国家。每个事件在技术上都是一个新的最新状态值，使以前的状态过时。这种类型的流程适用于只有最新状态才重要的情况，因为它的事件是混合的。从文档：

对值的更新总是混为一谈。因此，慢速收集器会跳过快速更新，但总是收集最近发出的值。

根据您的评论进行编辑：yield()是一个暂停功能，强制暂停当前协程。因此，它为另一个协程提供了一个机会，直到它的下一个暂停点，这就是为什么在这种情况下，在设置（并发出）第一个值之前，collect 已经“准备好”。

但是你不应该依赖它，因为它很脆弱：如果另一个协程被修改并且通过调用其他挂起函数具有额外的挂起点，它可能无法到达collect调用，你将回到其他行为。

如果您始终需要所有事件，您有多种选择：

  • 切换到冷流，只有在你收集时才会开始
  • 使用Channel（带或不带缓冲区）
  • 使用 aSharedFlow并通过使用触发事件onSubscription
于 2021-05-23T01:18:30.387 回答