相关疑难解决方法(0)

我正在尝试创建应该返回 201 响应的框架。当向 API 发出请求时，我想立即发回响应并在后台处理请求。

Flux.fromIterable(request.getApiRequests()).log().flatMap(item -> {

        WebClient.RequestHeadersSpec apiCallSpec = WebClient.create(request.getBasePath())
                .method(item.getHttpMethod()).uri(item.getPath()).accept(MediaType.valueOf(item.getAccept()))
                .contentType(MediaType.valueOf(item.getContentType())).body(BodyInserters.fromObject(item.getPayload()));

        return apiCallSpec.retrieve().bodyToMono(String.class);
    }).subscribe();

    return Mono.just("Created");

我希望通量部分发生在后台，但截至目前，一旦整个通量被流式传输，API 就会等待并响应。