zoukankan      html  css  js  c++  java
  • [RxJava^Android]项目经验分享 --- 异常方法处理

    简单介绍一下背景,最近RxJava很火,我也看来学习一下,计划在项目的独立模块中使用它。使用过程中遇到很多问题,在这里记录分享一下。可能有使用不当的地方,大家多多包涵。对于RxJava的基本概念和功能原理就不做介绍了。

    变换操作时,使用的方法是抛出异常的,如何处理:

    开始使用map操作,发现处理异常时,不能在订阅(Subscriber)的时候观察到onError。

    代码块

        public String changeFun(int i) throws Exception {
            if (i == 100) {
                throw new Exception("i == 100");
            } else {
                return "OK";
            }
        }
    
        public void test() {
            Observable.just(100).map((Integer integer) -> {
                try {
                    return changeFun(integer);
                } catch (Exception e) {
                    e.printStackTrace();
                }
                return "";
            }).subscribe(new Subscriber<String>() {
                @Override
                public void onCompleted() {
    
                }
    
                @Override
                public void onError(Throwable e) {
    
                }
    
                @Override
                public void onNext(String s) {
    
                }
            });
        }
    

    针对上面问题修改为操作符flatMap进行实现。

    代码块

            public String changeFun(int i) throws Exception {
                if (i == 100) {
                    throw new Exception("i == 100");
                } else {
                    return "OK";
                }
            }
        
            Observable.just(100).flatMap(integer -> Observable.create(subscriber -> {
                try {
                    subscriber.onNext(changeFun(integer));
                    subscriber.onCompleted();
                } catch (Exception e) {
                    subscriber.onError(e);
                }
            })).subscribe(new Subscriber<String>() {
                @Override
                public void onCompleted() {
                    Log.d(TAG, "onCompleted");
    
                }
    
                @Override
                public void onError(Throwable e) {
                    Log.d(TAG, "onError:" + e.toString());
                }
    
                @Override
                public void onNext(String s) {
                    Log.d(TAG, "onNext:" + s);
                }
            });
    

    flatMapmap在使用过程中的区别在于 flatMap返回Observable,而map返回Object。工作原理的差别自行查阅一下吧。

  • 相关阅读:
    Django入门
    Python从入门到放弃
    Python中的元类(metaclass)
    蓝鲸gse启动失败
    VS2019添加微软ReportViewer
    DevExpress WinForms各版本与 .NET、Visual Studio 的版本兼容性
    SQL语句查询每个分组的前N条记录的实现方法
    如何查看Windows安装版本号
    学习webpack
    Python3.x将代码打包成exe程序并添加图标
  • 原文地址:https://www.cnblogs.com/assassin-l/p/5054537.html
Copyright © 2011-2022 走看看