- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
在spring项目reactor中,onErrorResume
和doOnError
有什么区别?我什么时候应该分别使用它们?
最佳答案
onErrorResume
:当上游发生异常时提供回退流。
doOnError
:副作用运算符。假设您想记录上游发生的错误。
示例:
Mono.just(request)
.flatMap(this::makeHTTPGet)
.doOnError(err -> {
log.error("Some error occurred while making the POST call",err)
})
.onErrorResume(err -> Mono.just(getFallbackResponse()));
你看,doOnError
是一个副作用运算符。这就像将温度计插入水管并读取温度一样。它对管道有影响吗?没有。
假设现在管道破裂了 - 城市仍然需要供水,对吗?因此,我们有一个可以在这种情况下激活的后备管道。 onErrorResume
正是这样做的。
注意:您还可以登录onErrorResume
。没有什么可以阻止你这样做。
关于spring - onErrorResume 和 doOnError 的区别,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58167842/
我有pay方法,我应该在其中调用initiatePayment,并且onSuccess我应该调用confirmPayment。如果两个调用中的任何一个出现异常,它应该发出异常 public Singl
我刚刚开始使用 RxJava,但可能还没有点击。 1. Integer[] items = {1, 2, 3, 0, 0, 4, 5, 6, 1}; Observable.from(items)
在我们的项目中,如果发生不好的事情,我们有某种后备措施,并由 doOnError 处理。我唯一担心的是 doOnError 运算符可能没有以正确的方式使用。那么让我们看一下下一个示例: callSer
我尝试使用以下代码 initLocalSettingsIfNeed() .andThen(initGlobalSettingsIfNeed(co
感觉这应该很简单,所以我可能会遗漏一些明显的东西。我有一个简单的示例案例,其中出现了 Mono 错误,并且我希望使用通用处理程序进行特定于异常类的处理。 Mono.error(new Runt
在spring项目reactor中,onErrorResume和doOnError有什么区别?我什么时候应该分别使用它们? 最佳答案 onErrorResume:当上游发生异常时提供回退流。 doOn
我做了这些单元测试,结果根本不是我预期的: // This one outputs "subscribe.onError" @Test public void observable_doOnError
我有以下情况:我需要从数据库获取数据。当我尝试进入 UI 线程时(这是我的做法): List movies = new ArrayList<>(); for (MovieEntity movie:mo
我有以下代码。它基本上是尝试将特定 SQLite 表中的所有数据发送到 DynamoDB: Observable.create(new Observable.OnSubscribe() { @
我在使用 RxJava2(2.2.2 版)时遇到了问题。请参阅下面的代码: client.get("/iic-router/health").rxSend() .doOnError(err -
如果我正确理解错误和异常之间的区别,这些函数不应该命名为 doOnException() 或 Mono.exception(new Exception("...")) 等? 这里没有任何功能,只是一个
我有一个使用 spring webflux 和 reactor 的休息 Controller ,我正在为 Controller 编写单元测试。请在下面找到代码片段并帮助我编写单元测试方法来测试 .do
我是响应式编程的新手,因此需要一些帮助。我有下面的代码,我不喜欢两种不同的错误处理方法。 我想用一种方法将它们结合起来。正确的做法是什么? mono.doOnError(error -> logErr
在我的上一个项目中,我使用了 rxJava,我意识到 observable.doOnError('onErrorCallback').subscribe(action) 和 observable.su
我正在尝试实现 Reactor Subscriber Context ( http://projectreactor.io/docs/core/release/reference/#context )
谁能解释一下为什么要写这样的代码: networApi.getList() .subscribeOn(Schedulers.newThread())
我是一名优秀的程序员,十分优秀!