java - 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);
}