(emissionIntervalMillis))考虑一下这个实现,在这个实现中,UnicastProcessor订阅了以前的Flux[parallel-1] INFO reactor.Flux.Map.1 - onNext(0)
15:58:28.973 [parallel-1] INFO reactor.Flux.Map.1 -reactor.Flux.Map.
我正在使用Project Reactor和Webflux来尝试从消息队列中读取数据,然后分块处理(例如,一次处理五个),并对每个块向API发出请求。API在高吞吐量的情况下不能很好地工作,因此我需要控制并发发送多少请求。 基本上,我希望有一个WebClient调用finish,然后能够告诉Flux我们已经准备好处理更多。我使用这段代码来尝试模拟所需的功能,但得到的结果是我不理解的: fun main