java - 如何在运行时创建Mono序列

Question

我正在尝试根据用户输入动态创建 Mono 序列。我正在调用 Rest API 并在 Mono 中获取 ClientResponse。我的用例是按顺序调用 2 个或更多 API，并且下一个 API 的输入有效负载取决于前一个 API 的输出。

我的硬编码序列操作看起来像

    public Mono<ResponseEntity> processSequentially(ServerHttpRequest request, JsonNode reqBody) {
            RequestData reqData = this.prepareReqMetadata(request, reqBody);
            return commonConnector.getApiResponse(reqData)
                    .flatMap(resp -> resp.bodyToMono(JsonNode.class))
                    .flatMap(respBody -> getApiResponse(request, metadataRequestBuilder, respBody))
                    .flatMap(resp -> resp.bodyToMono(JsonNode.class))
                    .flatMap(respBody -> getApiResponse(request, listingRequestBuilder, respBody))
        }

这工作正常，但我想让这个方法通用。我想从 POJO 列表中的用户获取所有必需的参数，并根据列表输入创建 flatMap 序列。因此，如果List的长度为2，则将有2个flatMap序列，如果长度为3或更多，则flatMap的数量也将是3或更多。

Answer 1

在您订阅之前不会发生任何事情，因此您可以在简单的循环中应用转换。

public Mono<ResponseEntity> processSequentially(ServerHttpRequest request, List<JsonNode> reqBody) {
    RequestData reqData = this.prepareReqMetadata(request, reqBody);

    Mono ret = commonConnector.getApiResponse(reqData);

    reqBody.forEach(jsonNode -> ret.flatMap(resp -> resp.bodyToMono(JsonNode.class))
                                .flatMap(respBody -> getApiResponse(request, metadataRequestBuilder, respBody))
    );

    return ret;
}