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

Question

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

 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() 方法，但这不是我的目标我试过 return 这样的对象

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

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

Answer 1

这应该有效：

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

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

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

how to render an object with two flux fields without blocking?

mono

spring

reactive-programming

flux

spring-webflux