即使我没有CallbackListener，我也可以使用回调流吗

Question

我正在使用GraphQl从服务器获取数据。 SDK并非暂停，我正在尝试使用干净的体系结构。因此，我来​​到我的存储库中返回Flow，以允许用途服务器的响应。因此，我的存储库中有此代码：

override fun singUp(model: SignUpModel): Flow<ResponseModel<SignUpServerResponse>> = callbackFlow {
            ...
          
            client.mutateGraph(signUpQuery)
                .enqueue(object : GraphCallResultCallback<Storefront.Mutation> {
                    override fun invoke(result: GraphCallResult<Storefront.Mutation>) {

                        if (result is GraphCallResult.Success) 
                            trySendBlocking(...).also { close() }
                        else 
                            trySendBlocking(...).also { close() }
                    }
                })
            awaitClose {}
        }

我的问题是：

1-每个事件后我需要致电关闭吗？显然，在从服务器中获取响应后，我不需要流动。

2-我删除了等待{}，并且我发现需要此字段，并且应使用该字段来分离callbackListener，但是在这种情况下，我没有一个。如果我最后放置一个空的等待{}，可以吗？

3-我知道该流程在后台使用通道。我还通过频道实施了它，我必须使用回调流吗？

Answer 1

您不需要在此处使用callbackflow，就如注释中提到的那样。如果要使用coroutines使用singup（）方法，则需要将其转换为暂停函数。要将带回调的函数转换为暂停函数suppendCoroutine和suppendCancellableCoroutine可以使用构建器。例子：

suspend fun singUp(model: SignUpModel): ResponseModel<SignUpServerResponse> = suspendCoroutine { continuation ->
        ...
      
        client.mutateGraph(signUpQuery)
            .enqueue(object : GraphCallResultCallback<Storefront.Mutation> {
                override fun invoke(result: GraphCallResult<Storefront.Mutation>) {

                    if (result is GraphCallResult.Success) 
                        continuation.resume(...) // resumes an execution of a coroutine, in which the `singUp` method was called
                    else 
                        continuation.resume(...)
                }
            })
}