Spring WebFlux：并行调用的竞争，当其中一个响应有数据时取消/返回

Question

我有三个对三个不同endpoint的并行调用，其中只有一个将返回我要处理的数据（响应将只包含enpoint-1、enpoint-2或Enpoint-3的数据）。如果其中一个调用返回数据，我希望立即返回该数据，并忘记其他调用...我如何使用Spring WebFlux实现这一点？

Mono<MyResponse> result = client.post()
  .uri('uri')
  .body(Mono.just(request), MyRequest.class)
  .retrieve()
  .bodyToMono(MyResponse.class);

 List<Mono<MyResponse>> calls

Flux.merge(calls).toStream().forEach(response -> myResponseList.addAll(response));

谢了！

Answer 1

你只能取流量的第一个元素

 Flux.merge(calls).take(1)

你只得到第一个元素的新通量，它在产生它后就完成了。