#spring #reactive #webflux
Вопрос:
Я новичок в 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);
}