Mono：：然后返回null

Question

我对反应性编程相对较新。我的问题是关于mono::then

public Mono<ServerResponse> getStatus(ServerRequest req) {
        Mono<List<Request>> body = req.bodyToFlux(Request.class).collectList();
        return ServerResponse.ok()
                .body(body.doOnNext(i -> {
                    Service.a = i;
                    logger.info("Service started for : {}", i.toString());
                })


                        .then(Mono.just("Service started for: " + Service.a)), String.class);
    }

Answer 1

通过静态变量进行通信是非常不受欢迎的（尤其是在函数式和反应式编程中）。在您的问题中，您没有提供关于您启动的服务的足够信息，因此很难推荐。

然而，根据现有的信息，我将从以下内容开始：

public Mono<ServerResponse> getStatus(ServerRequest req) {
    return req.bodyToFlux(Request.class)
            .collectList()
            .doOnNext(requestBody -> System.out.println("Do your service start here in the background."))
            .flatMap(requestBody -> ServerResponse.ok().syncBody("Service started for: " + requestBody));
}