Блог

Я новичок в webflux. Я изучил основные операторы, но очень трудно понять, как их использовать. Предполагая , что существует функция, которая реагирует на поток, я хотел бы дать ответ некоторому объекту, у которого есть список в качестве переменной-члена. Что мне делать?

Result.java

 public class Result {
    List<Boolean> list;
}
 

Service.java

 Flux<Boolean> findById() {

...
}
 

Router.java

 public Mono<ServerResponse> getResult(ServerRequest request) {
    ...
    Mono<Result> result = Mono.just(new Result());
    result = result.map(a -> a.setList(service.findById())); // error.. how to set list from Flux<Boolean> function?
    return ServerResponse.ok().contentType(APPLICATION_JSON).body(result, Result.class);
}