spring - 如何组装反应功能模块？

Question

我是 webflux 初学者。基本的算子我都学过了，但是怎么用却很难应用。假设有一个响应 Flux 的函数，我想给响应一些具有 List 作为成员变量的对象。我应该怎么办？

结果.java

public class Result {
    List<Boolean> list;
}

服务.java

Flux<Boolean> findById() {

...
}

路由器.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);
}

标签： springreactivewebflux