如何从使用 .await() 调用的方法返回异常

Question

我正在使用新的 google services coroutines 扩展函数来实现从异步调用返回异常

suspend fun saveUserToken(user: User): Resource<Boolean> {
    val result = FirebaseInstanceId.getInstance().instanceId.await()
    user.deviceToken = result.token
    FirebaseFirestore.getInstance().collection("user").document(user.uid).set(user).await()
    return Resource.success(true)
}

这里我做了两个异步操作，第一个检索用户设备令牌，第二个将设备令牌+用户数据存储到 Firestore 中

现在我的问题是。

如果一个被抛出，我如何知道或从这两种方法返回异常？

由于是一个Task，异常应该以同一个对象的形式返回，我已经阅读了.await()方法，看看它是如何处理异常的

public suspend fun <T> Task<T>.await(): T {
    // fast path
    if (isComplete) {
        val e = exception
        return if (e == null) {
            if (isCanceled) {
                throw CancellationException("Task $this was cancelled normally.")
            } else {
                result
            }
        } else {
            throw e
        }
    }

    return suspendCancellableCoroutine { cont ->
        addOnCompleteListener {
            val e = exception
            if (e == null) {
                if (isCanceled) cont.cancel() else cont.resume(result)
            } else {
                cont.resumeWithException(e)
            }
        }
    }
}

这里有两种类型的异常，一种是调用它的任务异常（这是我想在我的第一个代码块中捕获的异常），第二种是取消协程时触发的 CancellationException

Answer 1

只需像使用任何其他代码一样使用 try/catch：

try {
    val result = FirebaseInstanceId.getInstance().instanceId.await()
    user.deviceToken = result.token
    FirebaseFirestore.getInstance().collection("user").document(user.uid).set(user).await()
    return Resource.success(true)
}
catch (e: Exception) {
    // handle the error here
}

或者您可以将 try/catch 放在对 saveUserToken 的调用周围。无论哪种情况，如果 try catch 中的挂起乐趣产生错误，您的 catch 就会触发。

我建议阅读exception handling with Kotlin coroutines 上的文档。