Mono::then 返回 null

Question

我对响应式编程比较陌生。 我的问题是关于Mono::then

我想要做的是，从传入的请求中提取正文，将其设置为静态变量。 完成后，发送一个响应，说明服务已启动。 但是下面的代码总是返回“Service started for: null”。

我认为Mono::then 应该在第一个单声道完成后运行（在这种情况下，在设置静态变量之后）并返回“Service started for: a,b,c”。

我的理解有误吗？

（另外，任何代码批评都表示赞赏）

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

非常不鼓励通过静态变量进行通信（尤其是在函数式和反应式编程中）。在您的问题中，您没有提供有关您开始的Service 的足够信息，因此有点难以推荐。

但是，根据现有信息，我会从以下内容开始：

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));
}