io.reactivex.internal.operators.flowable.FlowableZip$ZipSubscriber.onNext(FlowableZip.java:381) at io.reactivex.processors.UnicastProcessor.drain(UnicastProcessor.java:396)
Flux.interval(Duration.ofMillis(emissionIntervalMillis))考虑一下这个实现,在这个实现中,UnicastProcessorlatch = CountDownLatch(15)
val processor = UnicastProcessor.createparallel-1] INFO com.codepende