使用 Reactor 的 mergeDelayError 时,如果发出了不止一个错误,是否有办法获取所有错误而不是仅获取第一个错误?
Flux.mergeDelayError(10,
Flux.fromStream(Stream.of(1, 2, 3))
.flatMap(i -> Mono.error(new Exception(i.toString()))),
Mono.just(1),
Mono.just(2))
.doOnError(error -> log.error("error, {}", error.getMessage()))
.collectList()
.flatMap(Mono::just) .block();
上例只打印
error 1
,不打印error 2
就退出,error 3