七、RxJava异常处理onErrorReturn,onErrorResumeNext,onErrorResumeWith,retry
1.项目地址
在MainActivity7
2.讲解
需要在emitter.onError里面执行抛异常,这样才能抛异常,不报错。如
emitter.onError(new IllegalAccessException("我要报错了,你小心点,哈哈哈!"));
1.onErrorReturn
这个报错后,下游不会接收到消息,可以发射一个错误提示给下游,如发射一个404
// 用emitter.onError抛出异常的话,上游(观察者)还是会执行完。onErrorReturn会使下游(观察者)暂停接收,然后还可以返回一个错误值(类似网络报错,返回一个404)
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(@NonNull ObservableEmitter<Integer> emitter) throws Throwable {
for (int i = 0; i < 100; i ) {
if (i == 5) {
emitter.onError(new IllegalAccessException("我要报错了,你小心点,哈哈哈!"));
}
emitter.onNext(i);
Log.d(TAG, "subscribe: " i);//这个还是会执行完
}
emitter.onComplete();
}
})
.onErrorReturn(new Function<Throwable, Integer>() {
@Override
public Integer apply(Throwable throwable) throws Throwable {
Log.d(TAG, "apply: " throwable.getMessage());
return 400;
}
})
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
Log.d(TAG, "onSubscribe: ");
}
@Override
public void onNext(@NonNull Integer integer) {
Log.d(TAG, "onNext: " integer);
}
@Override
public void onError(@NonNull Throwable e) {
Log.d(TAG, "onError: ");
}
@Override
public void onComplete() {
Log.d(TAG, "onComplete: ");
}
});
2.onErrorResumeNext
错误发射后,可以创建一个被观察者,可以继续发射emitter.onNext(400);
//这个是error报错了,然后会重新创建一个被观察者,然后又可以执行emitter.onNext
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(@NonNull ObservableEmitter<Integer> emitter) throws Throwable {
for (int i = 0; i < 100; i ) {
if (i == 5) {
emitter.onError(new Error("错错错"));
}else {
emitter.onNext(i);
Log.d(TAG, "subscribe: " i);//这个还是会执行完
}
}
emitter.onComplete();
}
})
.onErrorResumeNext(new Function<Throwable, ObservableSource<? extends Integer>>() {
@Override
public ObservableSource<? extends Integer> apply(Throwable throwable) throws Throwable {
return Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(@NonNull ObservableEmitter<Integer> emitter) throws Throwable {
//只能执行两个
emitter.onNext(400);
emitter.onNext(400);
emitter.onNext(400);
emitter.onNext(400);
emitter.onNext(400);
emitter.onNext(400);
emitter.onComplete();
}
});
}
})
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
Log.d(TAG, "onSubscribe: ");
}
@Override
public void onNext(@NonNull Integer integer) {
Log.d(TAG, "onNext: " integer);
}
@Override
public void onError(@NonNull Throwable e) {
Log.d(TAG, "onError: ");
}
@Override
public void onComplete() {
Log.d(TAG, "onComplete: ");
}
});
3.onErrorResumeWith
感觉跟onErrorResumeNext差不多,可以继续发射
4.retry
表示报错后,重试。其中true表示重试,false表示不重试。一般都用true吧
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(@NonNull ObservableEmitter<Integer> emitter) throws Throwable {
for (int i = 0; i < 100; i ) {
if (i == 5) {
emitter.onError(new IllegalAccessException("错错错"));
}else {
emitter.onNext(i);
Log.d(TAG, "subscribe: " i);//这个还是会执行完
}
}
emitter.onComplete();
}
})
//一直重试
// .retry()
//重试一段时间后,再停止
// .retry(new Predicate<Throwable>() {
// @Override
// public boolean test(Throwable throwable) throws Throwable {
// Log.d(TAG, "test: " throwable.getMessage());
// return true;//false 代表不重试,true表示重试,一段时间后就是停止
// }
// })
//表示错误后,多少次重试,设置返回值是false的话,将不重试
// .retry(3, new Predicate<Throwable>() {
// @Override
// public boolean test(Throwable throwable) throws Throwable {
// return true;
// }
// })
//重复很多次,打印重复的次数
.retry(new BiPredicate<Integer, Throwable>() {
@Override
public boolean test(@NonNull Integer integer, @NonNull Throwable throwable) throws Throwable {
Thread.sleep(2);
Log.d(TAG, "test重试了: " integer "次" throwable.getMessage());
return true;
}
})
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
Log.d(TAG, "onSubscribe: ");
}
@Override
public void onNext(@NonNull Integer integer) {
Log.d(TAG, "onNext: " integer);
}
@Override
public void onError(@NonNull Throwable e) {
Log.d(TAG, "onError: ");
}
@Override
public void onComplete() {
Log.d(TAG, "onComplete: ");
}
});
1.retry()
表示一直重试
2.retry(new Predicate()
表示重试一段时间后,再停止
3.retry(3, new Predicate()
表示可以设置重试的次数,这里设置为重试3次
4.retry(new BiPredicate<Integer, Throwable>()
重试多次,然后打印重试的次数
这篇好文章是转载于:学新通技术网
- 版权申明: 本站部分内容来自互联网,仅供学习及演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,请提供相关证据及您的身份证明,我们将在收到邮件后48小时内删除。
- 本站站名: 学新通技术网
- 本文地址: /boutique/detail/tanhgbkjhe
系列文章
更多
同类精品
更多
-
photoshop保存的图片太大微信发不了怎么办
PHP中文网 06-15 -
《学习通》视频自动暂停处理方法
HelloWorld317 07-05 -
word里面弄一个表格后上面的标题会跑到下面怎么办
PHP中文网 06-20 -
Android 11 保存文件到外部存储,并分享文件
Luke 10-12 -
photoshop扩展功能面板显示灰色怎么办
PHP中文网 06-14 -
微信公众号没有声音提示怎么办
PHP中文网 03-31 -
excel下划线不显示怎么办
PHP中文网 06-23 -
excel打印预览压线压字怎么办
PHP中文网 06-22 -
TikTok加速器哪个好免费的TK加速器推荐
TK小达人 10-01 -
怎样阻止微信小程序自动打开
PHP中文网 06-13