如何使用协程将数据从存储库传递到 ViewModel

Question

This 的问题给了我一个大概的想法，但我仍在苦苦挣扎。

我的片段 -

// Reset email sent observer
viewModel.isEmailSent.observe(viewLifecycleOwner, { flag ->
    onResetMailSent(flag)
})

我的视图模型 -

val isMailSent: MutableLiveData<Boolean> = MutableLiveData(false)

isEmailSent = liveData {
                emit(firebaseAuthRepo.sendPasswordResetMail(emailId))
            }

我的仓库 -

suspend fun sendPasswordResetMail(emailId: String): Boolean {
   firebaseAuth?.sendPasswordResetEmail(emailId)
               ?.addOnCompleteListener {
                if (it.isSuccessful) { }
               }
               ?.addOnFailureListener {

               }
}

问题-

1. 如何通知视图模型 repo 的“addOnCompleteListener”或“addOnFailureListener”已被调用？我正在考虑返回一个布尔标志，但似乎我无法在侦听器中放置“返回”语句。

2. IDE 说 'suspend' 修饰符是多余的。这是为什么呢？

Answer 1

您可以使用suspendCoroutine，在这种情况下，它基本上可以作为一个钩子工作，您可以使用Continuation 对象处理回调内容。我们需要这个，因为firebaseAuth 已经在单独的线程上运行。试试下面的方法

suspend fun sendPasswordResetMail(emailId: String): Boolean {
    return withContext(Dispatchers.IO) {
        suspendCoroutine { cont ->
            firebaseAuth?.sendPasswordResetEmail(emailId)
                ?.addOnCompleteListener {
                        cont.resume(it.isSuccessful)
                }
                ?.addOnFailureListener {
                    cont.resumeWithException(it)
                }
        }
    }
}