转载

讨论下 RxJava 里的 onError

因为上次在网络请求里用到了 onErrorReturn 所以想自己实践下和搞清楚 RxJava 里异常处理到底是怎么回事，以及自己如何更好的使用。

public class RxJavaTest {
    static int[] arrayA = new int[2];
    static List<Integer> listB = new ArrayList<>();

    public static void main(String[] args) {
        listB.add(1);
        listB.add(2);
        listB.add(3);
        errorTest();
    }

    private static void errorTest() {
        Observable.from(listB)
            .doOnNext(integer -> arrayA[integer] = integer)
            .subscribe(integer -> {
            }, throwable -> {
                System.out.println("在onError处理了:" + throwable.toString());
            });
    }
}

可以看到我在这里模拟了一个越界异常，在 errorTest() 方法里做写了遍历列表 listB 并且将值赋值给数组 arrayA 对应角标。

运行以上程序在控制台输出的是：

在onError处理了:java.lang.ArrayIndexOutOfBoundsException: 2

现在我们做一点改变：

在 errorTest 方法里加入 onErrorReturn 并且返回 null

private static void errorTest() {
    Observable.from(listB)
        .doOnNext(integer -> arrayA[integer] = integer)
        .onErrorReturn(throwable -> {
            System.out.println("在onErrorReturn处理了:" + throwable.toString());
            return null;
        })
        .subscribe(integer -> {

        }, throwable -> {
            System.out.println("在onError处理了:" + throwable.toString());
        });
}

现在再运行程序得到在控制台的输出是：

在onErrorReturn处理了:java.lang.ArrayIndexOutOfBoundsException: 2

发现异常只在 onErrorReturn 处理了，并没有在 onError 里。

难道只要写了 onErrorReturn 处理了异常就不会抛到 onError 里吗？

带着这个疑问，我们再修改下 errorTest() 方法：

private static void errorTest() {
    Observable.from(listB)
        .doOnNext(integer -> arrayA[integer] = integer)
        .onErrorReturn(throwable -> {
            System.out.println("在onErrorReturn处理了:" + throwable.toString());
            return 3;
        })
        .doOnNext(integer -> arrayA[integer] = integer)
        .subscribe(integer -> {
        }, throwable -> {
            System.out.println("在onError处理了:" + throwable.toString());
        });
}

让 onErrorReturn 处理了异常后并且返回一个 3，随后继续进行赋值操作。

现在运行程序，控制台输出：

在onErrorReturn处理了:java.lang.ArrayIndexOutOfBoundsException: 2
在onError处理了:java.lang.ArrayIndexOutOfBoundsException: 3

总结

onErrorRetrun能够捕获在它之前发生的异常，它之后流中的操作发生的异常就它就不会管了。

经过小栗子的演示，我们现在理解了 onErrorReturn 的作用域，从而明白该什么是使用它。

原文 http://imxie.cc/2016/06/01/tao-lun-Rx-onError/

正文到此结束

所属分类：编程技术

本文标签： 目录 http 总结 list 遍历 java
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

讨论下 RxJava 里的 onError

目录

栗子

总结

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流