如何从回调中调用挂起函数？

Question

我有一个可挂起的 (updateData) 函数，它接受另一个挂起函数作为参数 (transform)。在我的updateData 函数中，我正在调用异步API，我需要将结果传递给transform 挂起函数。 我目前的问题是调用transform 函数显示消息“只能在协程上下文中调用暂停函数”。

代码如下：

override suspend fun updateData(transform: suspend (prefs: Preferences) -> Preferences): Preferences {
    return suspendCancellableCoroutine { continuation ->
        realtimeDatabase.runTransaction(object : Transaction.Handler {
            override fun doTransaction(currentData: MutableData): Transaction.Result {
                val prefs: Preferences = currentData.toPreferences()

                // I need to call the transform() function here
                
                // transform(prefs)
                // This call shows the error "suspension functions can be called only within coroutine context"
                
                return Transaction.success(currentData)
            }

            override fun onComplete(
                error: DatabaseError?,
                committed: Boolean,
                currentData: DataSnapshot?
            ) {
                if (error != null) {
                    continuation.resumeWithException(error)
                } else {
                    continuation.resume(currentData.toPreferences())
                }
            }
        })
    }
}

我找到了this similar question，但它并没有真正解决我的问题，因为我无法在doTransaction 之外调用transform 函数（我需要currentData）。

另外，我无法将 transform 设为正常的“非挂起”函数，因为我正在从另一个类覆盖该函数。

我的问题是：如何将transform 挂起功能应用于currentData？

Answer 1

我不知道你的 API 到底是什么，但也许你可以在 suspendCoroutine 块之后分解这个函数来进行转换，以便在协程而不是 API 回调中调用它。

override suspend fun updateData(transform: suspend (prefs: Preferences) -> Preferences): Preferences {
    val retrievedPrefs = suspendCancellableCoroutine { continuation ->
        realtimeDatabase.runTransaction(object : Transaction.Handler {
            override fun doTransaction(currentData: MutableData): Transaction.Result {
                return Transaction.success(currentData)
            }

            override fun onComplete(
                error: DatabaseError?,
                committed: Boolean,
                currentData: DataSnapshot?
            ) {
                if (error != null) {
                    continuation.resumeWithException(error)
                } else {
                    continuation.resume(currentData.toPreferences())
                }
            }
        })
    }
    return transform(retrievedPrefs)
}