用Spring Reactive WebClient同时流式传输请求/响应主体？

Question

Flux<Long> requests = Flux.interval(Duration.ofSeconds(2));

return WebClient.create()
        .post()
            .uri("/instructions")
            .contentType(MediaType.APPLICATION_STREAM_JSON)
            .body(requests, Long.class)
        .retrieve()
            .bodyToFlux(Object.class)
            .map(response -> {
                log.info("Received Response Object {}", response);
                return response;
            });

服务器是一个spring-boot-starter-webflux应用程序，具有路由处理程序，用于记录接收到的请求对象，并提供无限的结果流：

public Mono<ServerResponse> instructions(ServerRequest request) {
    // Log the request objects as they are received
    Flux<Object> requestStream = request.bodyToFlux(Object.class)
            .map(r -> {
                log.info("Received Request Object: {}", r);
                return r;
            });

    requestStream.subscribe();

    // Infinite stream of responses
    Flux<Long> responses = Flux.interval(Duration.ofSeconds(5));

    return ServerResponse.ok()
            .contentType(MediaType.APPLICATION_STREAM_JSON)
            .body(responses, Long.class);
}

当上面的代码运行时，服务器记录请求对象的无限流，但客户端从不记录任何响应对象。

如果通过执行以下操作绑定请求流:flux requests=flux.interval(duration.ofseconds(2)).take(20)； ，那么客户机在收到所有请求后开始记录响应。

Answer 1

请看这个问题：WebClient直到请求写入完成后才读取响应。

显然，基于Netty的WebClient只在发送完请求后才开始处理响应

Netty服务器也可能有类似的行为（只有在读取完请求正文后才开始发送响应），我不确定