java - 识别 Project Reactor 中 react 链中字节数组的来源

Question

我正在从 3 个灰度图像构建彩色图像。我使用 rsocket 对每个色带发出 3 个单独(并行)请求，该请求返回 Mono<byte[]> 。我需要将所有 3 个字节数组收集为一个列表，以便我可以正确构建图像。但是，我对如何在下一个 react 操作中识别字节数组属于哪个带感到困惑。

这里是一些示例代码:

 return Flux.just(redRequest, blueRequest, greenRequest)
                .parallel()
                .flatMap(client::getBytes) // calls the remote service to get the bytes for the given color band
                .sequential()
                .collectList()
                .map(response -> {
                   byte[] redBytes = response.get(0); //???
                }

我创建了一个包装类来保存原始请求、字节数组和带标识符，这样我就可以在每个操作中传递所有对象，但是因为我的 rsocket 客户端的响应是 Mono，所以我只能实现(可能错误的术语)通过在映射或平面映射中调用字节数组，此时我无法访问我的包装类，并且我不确定字节数组属于哪个带。

我可以通过不在并行请求中调用客户端来解决此问题吗？我能否保证项目将按照我在 Flux.just() 中定义的顺序在链中传播？ 。

基本上在最后一张图中，我只是想知道哪个字节数组属于哪个颜色带。

Answer 1

使用颜色字段将每个请求包装在对象中，并更改发送这些请求的管道的 flatMap 部分:

Flux.just(
  new Request(redRequest, RED),
  new Request(blueRequest, BLUE),
  new Request(greenRequest, GREEN)
)
.parallel()
.flatMap(request -> 
  client.getBytes(request)
    .map(response -> new Response(response.get(0), request.color))
)
.sequential()
.collectList()
.map(response -> {
  byte[] redBytes = response.bytes;
  Color color = response.color;
  // 
})