spring - 转换通量在单声道> 在 Spring Webflux 中

Question

我们正在使用 Spring Data 响应式，当我们调用时，findAll我们正在接收一个Flux<T>并且我们希望在 API 中公开这个响应，但是我们的 API 结构是

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

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

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

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

标签： springspring-webflux

Answer 1

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