15
我有5 Observable
s它与flatMap
链接。如果前四个Observable
s产生一个Exception
我想传播一个不同类型的Exception
到第五个。RxJava链观察和错误处理(自定义异常传播)
它是如何实现的?
谢谢。
P.S. 我想出这个尚未检验的解决方案:
flatMap(
// onNext
new Func1<BoolResponse, Observable<?>>() {
@Override
public Observable<?> call(BoolResponse boolResponse) {
return request;
}
},
// onError
new Func1<Throwable, Observable<?>>() {
@Override
public Observable<?> call(Throwable throwable) {
return Observable.error(new SomethingWentWrong());
}
},
// onCompleted
new Func0<Observable<?>>() {
@Override
public Observable<?> call() {
return request;
}
});
你认为这是OK?