当我第二次调用功能时，Kotlin流量什么都没有发出

Question

我尝试使用Kotlin Flow（共享流）在Firebaseauth中实现删除用户。 在OnDeleteAccountClicked（）中，有delete（）方法从firebaseauth调用，它可能会抛出AuthreAuthenticationRequiredException。当抛出异常时，应用程序将重定向到另一个片段以重新验证，然后再次调用ondeleteaccountclicked（），但流量没有发出。

viewModel

    private val _deleteAccount = MutableSharedFlow<() -> Unit>()

    fun onDeleteAccountClicked() {
        logd("outside the viewModelScope")
        viewModelScope.launch {
            logd("inside the viewModelScope")
            _deleteAccount.emit {
                logd("emitting log")
                firebaseAuth.deleteUser()
                //throw AuthReauthenticationRequiredException()
            }
        }
    }

    init {
        viewModelScope.launch {
            _deleteAccount
                .onEach {
                    it()
                }
                .catch {
                    if (it is AuthReauthenticationRequiredException) {
                        _redirectToSignInMethodsScreen.emit(Unit)
                    }
                }
                .collect()
        }
    }

logs“在ViewModelScope之外”和“在ViewModelScope内部”显示，每次调用该方法时都显示，但仅是第一次“发射log”。

我什至想以正确的方式做吗？

Answer 1

我刚刚测试了代码，它对我有用。我调用了 onDeleteAccountClicked() 三次，调用之间存在延迟，并且打印了 emit lambda 内的所有三个“发出日志”日志。尝试删除在 emit lambda 中调用 firebaseAuth.deleteUser() 并进行测试。当用户已被删除时调用 FirebaseUser.delete 函数会抛出 FirebaseAuthInvalidUserException 异常。也许这就是您没有看到日志的原因 - 因为 FirebaseUser.delete 函数抛出异常。

我认为用于仅调用一个函数的结构有点复杂，我建议摆脱 _deleteAccount 流程并将 firebaseAuth.deleteUser() 包装在 内>try-catch （您甚至不需要为此启动协程）：

fun onDeleteAccountClicked() {
    try {
        firebaseAuth.deleteUser()
    } catch(e: AuthReauthenticationRequiredException) {
        _redirectToSignInMethodsScreen.emit(Unit)
    }
}