Flux.mergeDelayError 获取所有错误

问题描述 投票:0回答:0

使用 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

java project-reactor reactive
© www.soinside.com 2019 - 2024. All rights reserved.