onErrorMap 和 onErrorContinue

Question

我正在学习使用 Flux/Mono 进行错误处理并遇到以下问题：

Flux.just("AAA", "BBB", "AAA", "CCC")
    .map(s -> {
        if (s.equals("AAA")) {
            throw new IllegalArgumentException();
        }
        return s;
    })
    .map(s -> s + "-LOL")
    .onErrorMap(IllegalArgumentException.class, cause -> new IllegalStateException())
    .onErrorContinue(IllegalArgumentException.class, (e, a) -> System.out.println("Found IllegalArgumentException" + e))
    .onErrorContinue(IllegalStateException.class, (e, a) -> System.out.println("Found IllegalStateException" + e))
    .collectList()
    .block();

我想做的是将一个错误异常映射到另一个异常，然后我想以特定的方式处理它。

在我的代码中，我看到onErrorContinue仅针对 触发IllegalArgumentException，但我不明白为什么 - 我刚刚将错误映射到IllegalStateException

Answer 1

如果您开始使用反应式编程，我强烈建议您避免onErrorContinue. 这是一个非常具有误导性的运算符，适用于非常了解运算符内部工作原理的高级用户。我很遗憾每次提到它时都添加一个，并且正在考虑将其隐藏在公共 API 中，因为它很容易被认为是像这样简单的。onErrorResume。

考虑onErrorReturn、onErrorResume、doOnError和subscribe(valueHandler, error -> doSomethingWithError(error))来代替。