spring - 在 Spring Webflux 中转换 Mono<Response<T>> 中的 Flux<T>

Question

我们正在使用 Spring Data 响应式(Reactive)，当我们调用 findAll 时我们收到 Flux<T>我们希望在 API 中公开此响应，但我们的 API 结构是

{
    "status": 200,
    "items": [ ... ]
}

因此，我们希望将其公开为 Mono<<Response<T>>

public class Response<T> {
    private int status;
    private List<T> items;
    // ...
}

如何转换Flux<T>在Mono<Response<T>>在 Spring Webflux 中？

Answer 1

Flux<User> users = //...
Mono<Response<User>> response = users.collectList().map(items -> new Response(items));