在RxJava中映射异常2

Question

如何将一个发生的异常映射到RxJava2中的另一个异常？ 例如：

doOnError(throwable -> { 
    if (throwable instanceof FooException) { 
     throw new BarException(); 
    } 
}) 

在这种情况下，我终于收到CompositeException是由FooException和BarException，但我想只接收BarException。帮帮我！

Answer 1

您可以使用onErrorResumeNext和返回Observable.error（）从它：

source.onErrorResumeNext(e -> Observable.error(new BarException())) 

编辑

该测试通过对我来说：

@Test 
public void test() { 
    Observable.error(new IOException()) 
    .onErrorResumeNext((Throwable e) -> Observable.error(new IllegalArgumentException())) 
    .test() 
    .assertFailure(IllegalArgumentException.class); 
}