腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(860)
视频
沙龙
1
回答
可用的
doOnError
{}没有解决由于订阅()中缺少onError处理程序而未处理的异常
、
、
、
、
AndroidSchedulers.mainThread()) .doOnNext { } Log.d("TAG", "
doOnError
${e.localizedMessage}") .takeUntil(disposeComposable但我显然添加了一个
doOnError
{}。此外,上面代码上的l
浏览 9
提问于2022-03-01
得票数 1
回答已采纳
1
回答
SpringWebFlux
doOnError
处理
、
、
在我们的项目中,如果发生了一些不好的事情,并由
doOnError
处理,我们就会有某种退步。我唯一关心的是,
doOnError
运算符可能没有以正确的方式使用。让我们来看下一个例子:.flatMap(service1Response -> {})当流到达
doOnError
时,我们调用另一个服务。在
doOnError
中,
浏览 1
提问于2019-05-31
得票数 0
1
回答
Mono -所有
doOnError
处理程序都会被调用。
、
、
return Mono.just(operation) .then(execute(operation)) .
doOnError
(Exception.class, this
浏览 8
提问于2020-06-15
得票数 1
回答已采纳
2
回答
可观测的
doOnError
正确位置
、
// Offer may have been removed from cache since last check .
doOnError
.
doOnError
的位置重要吗?另外,在这段代码中添加多个调用会产生什么效果?我已经意识到我可以做到这一点,所有这些都会被引用,但我不确定它的目的是什么。
浏览 0
提问于2015-04-27
得票数 16
回答已采纳
1
回答
RxJava对错误执行onErrorResumeNext(),但也采取一些行动
、
、
、
、
在迭代和获取web响应时,链会在遇到错误时停止。 .getRepos() //fetches all repos
浏览 1
提问于2018-06-12
得票数 1
回答已采纳
1
回答
RxJava retryWhen和onError
、
、
我开始使用rxJava进行开发,我有以下情况:retryWhen吞下错误,如何避免错误吞咽?
浏览 1
提问于2016-05-11
得票数 0
回答已采纳
1
回答
如果出现异常,则为flatMap短路。
、
、
、
我有一个flatMap,它运行一系列HTTP调用来注册用户、检索他们的配置文件以及其他一些事情。我想通过特定的错误消息通知subscription中的subscription,这取决于错误发生在flatMap的哪个阶段。也许注册是成功的,但是检索创建的配置文件并不成功。如果发生错误,我的flatMap如何才能停止所有后续的调用?Retrofit.registerUser() .observeOn(AndroidSchedulers.mai
浏览 4
提问于2015-07-15
得票数 1
2
回答
Rxjava -如何在
doOnError
完成后重试调用
、
、
、
我很难在之后重新尝试rxjava单次调用,另一个网络调用是用
doOnError
完成的: .subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()) getRefreshToken(it, AuthenticationManager.CallbacksubscribeBy(
浏览 1
提问于2018-10-24
得票数 1
1
回答
如何将异常从内部
doOnError
传播到外部
doOnError
?
、
、
confirmPaymentResponse -> doConfirmationLogic(confirmPaymentResponse )) }) .
doOnError
(如何将异常从内部
doOnError
传播到外部
doOnError
浏览 0
提问于2019-04-11
得票数 0
回答已采纳
2
回答
RxJava:
doOnError
(‘回调’)和订阅(*,‘回调’)中的回调有什么区别?
、
、
在我的上一个项目中,我使用了rxJava,我意识到observable.
doOnError
('onErrorCallback').subscribe(action)和observable.subscribe
浏览 4
提问于2015-05-15
得票数 19
回答已采纳
1
回答
Java WebClient
doOnError
和doOnSuccess方法都发生在单个请求中。
、
、
、
、
logger.info("Successfully send SMS to : {} with {} ", clientId, provider.getSarShomare())) .block(); 在某些情况下,
doOnError
浏览 12
提问于2022-01-19
得票数 0
1
回答
在飞行模式后引发HiveMQ异常,会话已过期,因为连接已关闭
、
、
、
connectScenario = client.connect(connect) .
doOnError
.andThen(publishConnect) .
doOnError
浏览 27
提问于2019-09-19
得票数 0
回答已采纳
1
回答
反应堆:检测空信号,使其能够在空的Mono上工作
、
、
是否有操作人员或好的方法来实现项目反应堆Mono的doOnEmpty()行为?这就是我现在拥有的: .map(value -> new Wrapped(value)) .doOnEach( ... ) wrapped.value == null ? 所以我正在包装实际价值,或者在空的情况下创建空的包装。
浏览 0
提问于2019-02-26
得票数 3
1
回答
从通量中获取所有的响应
、
、
、
、
我试图从流动中得到所有的反应,但有时我得到了所有的反应,有时我得到的反应并不是很少。有人能帮我一下吗。我已附上这张照片作为参考。我不想订阅那个通量。我要那些数据是用来操纵的。 public LinkedHashMap<String String> getDummyHealthData (Map<String Strings urls) {Mono.when(Flux. f
浏览 3
提问于2022-05-23
得票数 -2
1
回答
RxJava
doOnError
和onErrorReturn是如何工作的?
、
、
我做了这些单元测试,结果与我所期望的完全不同:@Test Observable<String> obs = getErrorProducingObservable(); obs.
doOnError
(throwable -> System.o
浏览 1
提问于2015-09-02
得票数 27
回答已采纳
2
回答
Junit部分覆盖了webclient的
doOnError
方法的代码
、
、
、
、
MediaType.APPLICATION_JSON) .retrieve() .
doOnError
retrieve(); when(responseMock.
doOnError
} when executing the test case, it&
浏览 4
提问于2021-12-13
得票数 0
1
回答
doOnError
不捕获异常
、
、
、
Integer[] items = {1, 2, 3, 0, 0, 4, 5, 6, 1}; .map(this::invert) .
doOnError
浏览 2
提问于2017-01-06
得票数 13
回答已采纳
1
回答
Mono.fromCallable中的异常不会导致错误
、
、
、
根据我的理解和经验,fromCallable应该包装任何遇到的异常,然后可以使用
doOnError
处理这些异常,但是,错误直接显示在控制台中。} fun updateUser(userDto: UserDto): Mono<User
浏览 119
提问于2019-05-24
得票数 2
回答已采纳
1
回答
如何在出现错误时将Mono转换为Mono<Void>
我正在尝试写一种方法来做这样的事情 Mono<Void> mv = ma.map( a -> ....) #some logic to perform with `A` 诀窍是,ma很可能会失败,然后我只想记录一下情况,并返回一个没有错误就完成的Mono<Void>。 看看Mono api,我刚刚找到了onErrorResume或onErrorReturn,但两者都会使用一个返回A的函数(这是我无法伪造的),而我想返
浏览 1
提问于2019-12-18
得票数 2
回答已采纳
1
回答
如果我使用onError进行指数回退,如何接收retryWhen回调中的错误
、
、
、
、
我在rxjava中使用retrofit 2,并且我使用retry with函数实现了指数后退,但是当请求失败时,我不会收到onError回调中的错误,但是我会立即收到onCompleted。这是我的代码: .retryWhen(attempts -> attempts.zipWith(Observable.range(1, 3), (n, i) -> i)
浏览 2
提问于2016-07-01
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
云直播
活动推荐
运营活动
广告
关闭
领券