您可以使用onErrorResumeNext并从中返回Observable.error():
source.onErrorResumeNext(e -> Observable.error(new BarException()))
编辑
该测试对我来说是合格的:
@Testpublic void test() { Observable.error(new IOException()) .onErrorResumeNext((Throwable e) -> Observable.error(new IllegalArgumentException())) .test() .assertFailure(IllegalArgumentException.class);}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)