我正在尝试理解doAfterTerminate是如何与delaySequence一起工作的。testDoAfterTerminate() { val sch = Schedulers.single()22:27:55.562 [single-1] INFO leon.patmore.kafkareacti
我有一个从8个元素的Iterable (Flux.fromIterable(..))构建的flux。对于每个通量排放,我想异步调用一个方法。.), executor),它将flux转换为flux<CompletableFuture<Boolean>>。
现在,我希望仅在最后一项完成时才继续流程。我尝试使用all(..)和take(size of the Iterable),但在这两种情况下,流程都会在所有元素完成之前继续。我假设这是因为我的exe