使用协程使函数返回在回调中获得的值

debugcn 发表于 Dev

路易斯·费尔南德斯（Luis Fernandez）

我对异步开发和特别是协程不是很熟悉。我要说的基本上是，我什至不知道我要实现的目标是否可行。

我有一个方法sendAudioMessage，我想返回一个字符串。这是（模糊的）代码：

override suspend fun sendAudioMessage(): String {
   // ... Do some stuff
   val listener: WebSocketUtils.Listener = object: WebSocketUtils.Listener {
      // ... some (not relevant) functions
      override fun onDisconnect(code: Int, reason: String?) {
         //Do some stuff
         return "myResult -> $code" //This obviously doesn't compile since is trying to make onDisconnect return a string instead of Unit
      }
   }
}

然后我想这样称呼它：

override fun send(request: String) {
    CoroutineScope(IO).launch {
        val response = d.sendAudioMessage()
        analyzeResponse( response, request )
    }
}

这有可能吗？如果是这样，我该如何实现？

格伦·桑多瓦尔（Glenn Sandoval）

您需要将回调包装在一个suspendCancellableCoroutine块中，以便将您的阻塞API调用转换为挂起函数，以便可以从协程调用它。它是这样的：

suspend fun sendAudioMessage(): String = suspendCancellableCoroutine { continuation ->
    WebSocketUtils.Listener {
        // ... some (not relevant) functions
        override fun onDisconnect(code: Int, reason: String?) {
            //Do some stuff
            when (code) {
                OK -> continuation.resume("myResult -> $code")
                ERROR -> continuation.resumeWithException(Exception(reason))
            }
        }
    }
}

当API调用成功返回时，您可以将结果返回给协程调用，continuation.resume并以结果作为参数。

当API调用返回错误时，您可以引发异常调用continuation.resumeWithException。

现在，您可以sendAudioMessage在协程内部调用并照常使用其结果：

class MyClass: CoroutineScope by CoroutineScope(Dispatchers.Default) {
    
    ...
    
    override fun send(request: String) {
        launch(Dispatchers.IO) {
            val response = d.sendAudioMessage()
            analyzeResponse(response, request)
        }
    }
    
    ...
}

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。