Spring Flux等待阵列完成填充导致阻塞

Question

我正在调用一个APIendpoint，该endpoint返回数据作为

{"length":850,"maxPageLimit":2500,"totalRecords":1700,
"data":[
{"date":"2022-06-29","newCasesByPublishDate":14476,"cumCasesByPublishDate":2005335},
{"date":"2022-06-26","newCasesByPublishDate":0,"cumCasesByPublishDate":1990859},
....
]}

#Response headers
X-Firefox-Spdy  h2
cache-control   public, must-revalidate, max-age=90
content-encoding    gzip
content-location    https://api......&format=json&page=1
content-security-policy default-src 'none'; style-src 'self' 'unsafe-inline'
content-type    application/vnd.PHE-COVID19.v1+json; charset=utf-8

我希望将数据数组中的每个条目作为flux jsonnode流返回。但是，在执行此操作之前，它会等待阵列完成。如何防止web客户端调用在阵列完成之前等待和阻止调用？或者这是预期的行为，我需要从所有者API请求更改以反应式方式发送数据？

    public Flux<JsonNode> fetchCovidStatsFor(Area area, AreaType areaType, List<Metrics> metricsList) {
        var request =  generateWebClient().get()
                .uri(uriBuilder -> uriBuilder
                        .queryParam(buildRequestFilters(area, areaType))
                        .queryParam(buildRequestStructures(metricsList))
                        .build())
                .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
        log.debug("request URI: {}", request.httpRequest(ClientHttpRequest::getURI));
        return request.retrieve()
                .bodyToFlux(JsonNode.class)
                .map(jsonNode -> jsonNode.get("data"))
                .doOnNext(jsonNode -> {System.out.println(jsonNode);});
    }

Answer 1

被调用的API控制数据流，因此应将其更改为以流的形式生成数据。这是一个使用MediaType的示例API。APPLICATION\u NDJSON\u值：

@GetMapping(produces = MediaType.APPLICATION_NDJSON_VALUE)
public Flux<JsonNode> list(){
    return service.list().delayElements(Duration.ofSeconds(1));
}