为什么 trySend 会发出假数据？

我需要在 MVVM 中获取用户身份验证状态。在存储库中我这样做：

override fun getAuthResponse() = callbackFlow  {
    val listener = AuthStateListener {
        Log.d(TAG, "currentUser: " + (currentUser == null)) //Line2
        trySend(it.currentUser == null)
    }
    auth.addAuthStateListener(listener)
    awaitClose {
        auth.removeAuthStateListener(listener)
    }
}

“Line2”将始终打印true因为用户没有经过身份验证。然后在 ViewModel 中我有：

fun getAuthResponse() = repo.getAuthResponse()

以及内部活动：

setContent {
    //...
    val response = viewModel.getAuthResponse().collectAsState(initial = false).value
    Log.d(TAG, "response: $response") //Line1
}

由于 setContent 是一个可组合函数，因此当我打开应用程序时，它会触发两次。这意味着“Line1”处的日志语句被触发两次。当它第一次点火时，我得到：

response: false
currentUser: true

因此，即使我在前一行调用了 getAuthResponse()，响应也会在之前打印。问题是，由于某种原因，即使当前用户为空，我也会在活动中打印出该用户不为空。当它第二次触发时，我得到了正确的数据：

response: true
currentUser: true

为什么我得到一个非空的用户对象？ trySend 会发出假数据吗？

这里的问题是流在设计上是异步的。即使你期望AuthStateListener注册后立即调用，该流程最初仍然没有任何值。collectAsState()需要一个值，它不能只是空的，因此它要求您提供一个初始值。您提供的false这就是你最初得到的response。然后几乎立即调用侦听器，它发出true进而response更改为true以及。

我们有多种方法可以解决此类问题。例如，我们最初可以显示加载屏幕，直到获得正确的值。在上面的例子中，我们可以得到currentUser直接，不使用侦听器，所以我建议使用StateFlow反而。StateFlow与常规不同Flow因为它能够保持其“当前”值。最简单的是使用MutableStateFlow:

override fun getAuthResponse(): StateFlow<Boolean> {
    val flow = MutableStateFlow(auth.currentUser == null)

    val listener = AuthStateListener {
        Log.d(TAG, "currentUser: " + (currentUser == null)) //Line2
        flow.value = it.currentUser == null
    }
    auth.addAuthStateListener(listener)

    return flow
}

setContent {
    //...
    val response = viewModel.getAuthResponse().collectAsState().value
    Log.d(TAG, "response: $response") //Line1
}

这个解决方案可能不是 100% 正确，因为我无法测试它，但我希望你能明白。