Преобразовать Flux <T>в моно в Spring Webflux - PullRequest
0 голосов
/ 19 июня 2020

Мы используем реактивную Spring Data, и когда мы вызываем 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?

1 Ответ

1 голос
/ 22 июня 2020
Flux<User> users = //...
Mono<Response<User>> response = users.collectList().map(items -> new Response(items));
...