项目反应器-如果完成了其他两个并行通量请求，则取消Flux REST API请求

Question

我并行运行几个REST API请求。如果至少2个请求成功完成，则所有其他请求应终止。如何使用项目反应器(Spring Webflux)和Flux实现这一目标?

Answer 1

您是否想要像Flux#take(long n)

您可以热切地订阅您的发布者，只发出n元素，并取消其余的

。在你的例子中，它看起来像这样:

List<Publisher<YourType>> publishers = ...;
Flux.merge(publishers)
.take(2)
.......
.......
.subscribe(...) or return the publisher to Webflux (if you are using it)