java - 使用 Flux 从服务中无限拉取

Question

我想要一个调用服务（阻塞调用）并在并行线程上进行处理的无限拉循环。我想按需调用服务，我的意思是如果我的服务能够处理新任务然后再次调用阻塞服务（也许是背压？）。首先我想用 Flux 来实现它，但是如果你有更好的想法，请与我分享。:)

我的想法是：

Flux calls blocking service on demand
apply backpressure or limit
using parallel processing
  process the response
subscribe()

谢谢！

标签： javaconcurrencyproject-reactorflux