如何在不阻塞的情况下渲染具有两个通量场的对象？

Question

我想渲染一个由两个单声道或通量元素组成的对象（在代码 sn-p 下方）：

 Mono<List<NodeDTO>> nodeDTOFlux = this.webClient
            .get()
            .uri(NODES_WITH_LIMIT + limit)
            .retrieve()
            .onStatus(HttpStatus::isError,
                    response -> response.bodyToMono(String.class).flatMap(
                            msg -> Mono.error(new ApiCallException(msg, response.statusCode())))
            )
            .bodyToFlux(new ParameterizedTypeReference<Node>() {
            }).map(node -> nodeMapper.toNodeDTO(node))
            .collectList();



    Mono<List<EdgeDTO>> edgeDTOFlux = this.webClient
            .get()
            .uri(EDGES_WITH_LIMIT + limit)
            .retrieve()
            .onStatus(HttpStatus::isError,
                    response -> response.bodyToMono(String.class).flatMap(
                            msg -> Mono.error(new ApiCallException(msg, response.statusCode())))
            )
            .bodyToFlux(new ParameterizedTypeReference<Edge>() {
            }).map(edge -> edgeMapper.toEdgeDTO(edge))
            .collectList();

我尝试了 zip() 方法，但这不是我的目标 我试图返回这样的对象

    GraphDataDTO graphDataDTO = new GraphDataDTO();
    graphDataDTO.setEdgeDTOS(edgeDTOFlux);
    graphDataDTO.setNodeDTOS(nodeDTOFlux);

我的控制台中有结果，但对象返回 { “nodeDTOS”：{ “扫描可用”：真 }, “边缘DTOS”：{ “扫描可用”：真 } } 返回是在获得所有通量之前完成的。有没有不阻塞的解决方案！ 提前致谢。

Answer 1

这应该可行：

return Mono.zip(nodeDTOFlux, edgeDTOFlux)
      .map(tuple2 -> GraphDataDTO.builder().nodeDTO(tuple2.getT1()).edgeDTO(tuple2.getT2()).build())

它创建一个 NodeDTO 和 EdgeDTO 的元组并将其映射到 GraphDataDTO。