Spring WebFlux + Kotlin 响应处理

Question

在将 Spring WebFlux 与 Kotlin 协程结合使用时，我很难理解所谓的简单 RESTful WS 响应处理场景。假设我们的 REST 控制器中有一个简单的 WS 方法，它应该返回可能大量（数百万）的响应“事物”：

@GetMapping
suspend fun findAllThings(): Flow<Thing> {
    //Reactive DB query, return a flow of things
}

这符合预期：只要使用流媒体类型（例如“application/x-ndjson”），结果就会流式传输到客户端。在更复杂的服务调用中，也考虑到错误/警告的可能性，我想返回以下形式的响应对象：

class Response<T> {
    val errors: Flow<String>
    val things: Flow<T>
}

这里的想法是响应要么成功（返回空错误流和事物流），要么失败（错误包含在相应的流中，而事物流为空）。在阻塞编程中，这是一个非常常见的响应习语。我现在的问题是如何使这个习语适应 Kotlin/Spring WebFlux 中的反应式方法？

我知道它可以只返回描述的响应（或 Mono 对于 Java 用户），但这有点违背了反应的目的，因为整个 Mono 在序列化时必须存在于内存中。有没有办法解决这个问题？我现在能想到的唯一可能的解决方案是自定义 Spring 编码器，它足够智能，可以流式传输错误或事物（无论存在什么）。

Answer 1

如何根据Thing 返回成功/错误？

class Result<T> private constructor(val result: T?, val error: String?) {

    constructor(data: T) : this(data, null)
    constructor(error: String) : this(null, error)
    val isError = error != null

}

@GetMapping
suspend fun findAllThings(): Flow<Result<Thing>> {
    //Reactive DB query, return a flow of things
}