从协程/挂起函数创建“Uni”

Question

我们使用夸克斯来处理在常规函数上运行的消息，因为我们基本上必须调用挂起函数

fun process (msg:Message):Message{
    val resFrom:Data = runBlocking{fetchDataFromDB(msg.key)}
    val processedMsg = processRoutingKey(msg,resFrom)
    return processedMsg

}

我们希望以Uni的形式获取数据(https://smallrye.io/smallrye-mutiny/getting-started/creating-unis)所以基本上我们想回去

fun process (msg:Message){
    val resFrom:Uni<Data> = ConvertUni {fetchDataFromDB(msg.key)}
}

我们需要进一步下游的uni一次来处理一些数据，但我们想从方法含义返回Uni

fun process (msg:Message):Uni<Message>{
    val resFrom:Uni<Data> = ConvertUni {fetchDataFromDB(msg.key)}
    val processed:Uni<Message> =process(msg,resfrom) 
    return processed 

}

Answer 1

签名fun过程（消息：Message）：Uni

在协程世界中，这意味着您需要启动协程。但是，与任何异步机制一样，它要求您意识到它将在哪里运行以及运行多长时间。这由您用来启动协程的CoroutineScope定义，这就是为什么async等协程构建器需要这样的范围。

因此，如果希望函数启动一个持续时间比函数调用长的协同例程，则需要将一个协同例程作用域传递给函数：

fun CoroutineScope.process(msg:Message): Uni<Message> {
    val uniResult = async { fetchDataFromDB(msg.key) }.asUni()
    return process(msg, uniResult) 
}

此处<代码>延迟

接受CoroutineScope作为接收器意味着方法的调用者可以选择此协程的范围，这将在适当时自动取消协程，并且还将定义运行协程的线程池/事件循环。

现在，考虑到这一点，您会看到您将在同一级别的API中混合使用协程和Uni，这不是很好。我建议一直坚持挂起函数，直到您真的必须转换为Uni。