Spring WebFlux静态编程语言响应处理

Question

当结合使用SpringWebFlux和Kotlin协同程序时，我很难理解一个简单的RESTfulWS响应处理场景。假设我们在REST控制器中有一个简单的WS方法，该方法可能返回大量（数百万）响应“things”：

@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>
}

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

我知道有可能只返回所描述的响应（或单声道）

Answer 1

每个事件返回成功/错误如何？

kotlin prettyprint-override">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
}