寻找一种处理RxJava中错误的干净方法

Question

我正在学习RxJava，并且在很多地方看到可以通过这种方式处理错误：

repository.getById(10).subscribe(new Action1<User>() {
            @Override
            public void call(User user) {
              //Do something
            }
        }, new Action1<Throwable>() {
            @Override
            public void call(Throwable t) {
                if (t instanceof FirstErrorException) {
                    handleFirstError((FirstErrorException) t);
                } else if (t instanceof FirstErrorException) {
                    handleSecondError((SecondErrorException) t);
                } else {
                    //and so on... 
                }
            }
        });

我是唯一认为这确实是错误代码的人吗？我该如何做得更好？我虽然使用Visitor了“访问”我的基本异常的每种具体类型的模式，但是onError方法始终需要一个Action1<Throwable>;。您不能使用自己的基本异常Throwable。

Answer 1

错误处理程序：

 <T,E extends Throwable> Observable<T>
 whenExceptionIs(Class<E> what, Func1<E,Observable<T>> result) {
     return t -> {
        return what.isInstance(t) ? result.call(t) : Observable.error(t);
     };
 }

您可以这样使用：

Observable<Foo> obs = ...
    .onErrorResumeNext(whenExceptionIs(IllegalArgumentException.class, t-> Observable.just(Foo.newInstance())))
    .onErrorResumeNext(whenExceptionIs(IOException.class, t-> Observable.error(new XyzzyException("",t))))
 ....