Reactor: Mono: 结合两种方法 doOnError 和 onErrroMap

Question

我是 Reactive 编程的新手，所以需要一些帮助。我有以下代码，其中我不喜欢两种不同的错误处理方法。 我想将它们组合成一种方法。正确的做法是什么？

mono.doOnError(error -> logError(error))
    .onErrorMap(
        t -> !(t instanceof DatabaseException),
           t -> DatabaseExceptionMapper.mapException(t));

Answer 1

您可以在 onErrorMap 本身添加日志。

flux.onErrorMap(err -> {
    logError(err);
    //return transformed exception
})