我有这样的代码:
List<Mono> monoList = foo();
//await when all Monos are finished
try {
Flux.fromIterable(monoList)
.flatMap(Function.identity())
.then()
.block();
} catch (Exception e) {
log.warn("error", e);
}
当所有 MONO 都成功完成时,它工作得很好,但如果至少一个 Mono 完成错误,它就不起作用。方法block
抛出异常并中断所有其他单声道。因此,当所有单声道成功完成或发生第一个错误时,此代码将等待。
当所有 Monos 完成时如何等待monoList
(成功与否无关紧要)