创建发出侦听器回调结果的Kotlin coroutine延迟对象

Question

我目前正在一个项目中从RxJava切换到Kotlin coroutines，用coroutine含水层替换所有单一和可观察的返回类型。我仍然在为以下结构而挣扎：一个接口（例如存储库的接口）提供数据查询访问并返回一个RxJava single。该实现使用Single.Create创建单个对象，并使用onSuccess/onError发出结果。现在，实现检索数据所需要做的是创建一个带有回调的侦听器，并将该侦听器注册到某个东西。然后，创建的侦听器的回调将在自创建的single上调用onsuccess/onerror。例如。使用firebase（尽管我的问题不是firebase特定的）：

interface Repository {
    fun getData(query: Query): Single<DataSnapshot?>
}

fun getData(query: Query): Single<DataSnapshot?> = Single.create { emitter ->
    query.addListenerForSingleValueEvent(object : ValueEventListener {
        override fun onCancelled(error: DatabaseError?) {
            emitter.onError(Exception())
        }

        override fun onDataChange(data: DataSnapshot?) {
            emitter.onSuccess(data)
        }
    })
}

现在我想要的是返回coroutine deferred的html" target="_blank">接口方法。如何创建实现，以便还可以注册一个具有回调的侦听器，其结果将由延迟的？我看不出这些协同构建器（如async、launch等）能做onSuccess/onError会做的事情。

interface Repository {
    fun getData(query: Query): Deferred<DataSnapshot?>
}

Answer 1

我的建议如下：

interface Repository {
    suspend fun getData(query: Query): Result<DataSnapshot>
}

其中Result可能是一个包含成功和错误情况的密封类：

sealed class Result<T> {
    class Success<T>(result: T) : Result<T>()
    class Error<T>(error: String) : Result<T>()
}

这样，在getData的实现端，您可以做到：

return Success(yourData)

return Error("Something went wrong")

通常，在处理协程时，您应该避免返回deferred，并尝试将它们“作为同步方法”使用。

编辑：现在我明白了这个问题，我希望这有助于解决它：

//This is as generic as it gets, you could use it on any Query, no need to retype it
suspend fun Query.await(): DataSnapshot = suspendCoroutine{cont ->
    addListenerForSingleValueEvent(object : ValueEventListener{
        override fun onCancelled(error: DatabaseError?) {
            cont.resumeWithException(error?: Exception("Unknown Error"))
        }

        override fun onDataChange(data: DataSnapshot?) {
            if(data != null){
                cont.resume(data)
            } else {
                cont.resumeWithException(Exception("Null data"))
            }

        }
    })
}
//this is your actual implementation
suspend fun getData(query: Query):DataSnapshot =
        query.await()

此代码假设DatabaseError extends Exception或Throwable。如果不是，您需要为它创建一个包装类型，或者使用我的原始解决方案，并且在这两种情况下都使用常规的简历。