高考报名时间2022年11月1日还剩 天 距离2023年6月7日高考还有 天
栏目分类:
子分类:
返回
名师互学网用户登录
名师互学网
快速导航关闭
当前搜索
当前分类
前沿技术 软件开发 系统运维 产品运营 生活办公 面试经验 考试题库
子分类
人工智能 大数据 云计算 区块链 物联网 深度学习 机器学习 NLP 计算机视觉 语音识别 其他 大数据系统 数据可视化 数据挖掘与分析 其他 Docker/k8s 虚拟化 云平台 其他 基本原理 数字货币 智能合约 EOS应用 其他 通讯技术 嵌入式开发 单片机 物联网应用 HarmonyOS 其他 后端开发 Web开发 移动开发 游戏开发 Python Java 架构设计 C/C++/C# PHP .Net Go语言 R语言
实用工具
学习工具 小学数学练习 字帖生成 在线画板 函数绘制 拼音字母表 在线词典 黄历查询 亲戚关系计算 安全期计算 中国历史 Excel函数 模拟请求 json格式化 浏览器指纹
热门搜索
路由器设置 木托盘 宝塔面板 儿童python教程 心情低落 朋友圈 vim 双一流学科 专升本 我的学校 日记学校 西点培训学校 汽修学校 情书 化妆学校 塔沟武校 异形模板 西南大学排名 最精辟人生短句 6步教你追回被骗的钱 南昌大学排名 清朝十二帝 北京印刷学院排名 北方工业大学排名 北京航空航天大学排名 首都经济贸易大学排名 中国传媒大学排名 首都师范大学排名 中国地质大学(北京)排名 北京信息科技大学排名
名师互学网 > IT > 软件开发 > 后端开发 > Java

Rxjava

Java 更新时间： 发布时间： IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Rxjava

  1. 依赖
  2. 五种被观察者
  3. 订阅者
  4. 创建操作符
  5. 转换操作符
  6. 组合操作符
  7. 功能操作符
  8. 过滤操作符
  9. 条件操作符
  10. 自定义Observer
  11. 对上下游所处线程进行封装

1.依赖

implementation 'io.reactivex.rxjava2:rxjava:2.2.21'
implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
implementation 'com.jakewharton.rxbinding2:rxbinding:2.1.1'//实现防抖功能

2.五种被观察者
（1）Observer

    Observer observer = new Observer() {
        private Disposable disposable;
        
        @Override
        public void onSubscribe(@NonNull Disposable d) {
            //事件订阅成功回调，返回Disposable请求实例，可以通过d.dispose()中断传递请求
            //最先被回调 一定执行在主线程里
            System.out.println("onSubscribe()");
            //可以获取到d
            disposable = d;
        }

        @Override
        public void onNext(@NonNull Object o) {
            响应事件的方法，接收事件数据
            System.out.println("onNext()" + o);
            //可以切断传递
            disposable.dispose();
        }

        @Override
        public void onError(@NonNull Throwable e) {
            //事件队列异常，不再接收新的事件
            System.out.println("onError()" + e);
        }

        @Override
        public void onComplete() {
            //事件队列完结，不再接收新的事件
            System.out.println("onComplete()");
        }
    };
 

3.订阅者
 

4.创建操作符
 （1） create()
 


 （2）just()
 简化Create操作，最多只能传入10个参数
 
 （3）fromArray()
 简化Create操作 可能传入无限个参数
 
 

（4）fromFuture()
 与线程安全有关
 
 （5）fromIterable()
 可以传入继承了Iterable接口的集合
 
 （6）range()
 可以方便确定范围
 


 5.转换操作符
 （1）map()
 可以将被观察者发送的数据类型转变为其他类型
 
 

（2）flatMap()
 可以将事件序列中的元素进行加工，一一返回新的被观察者(s)
 
 

可以处理嵌套for循环、嵌套网络请求的情况

 

（3）concatMap()
 在flatMap的基础上保证转发出来的事件是有序的
 

（4）buffer()
 从需要发射的事件序列中放进缓存区，达一定数量时一起发送
 

 

6.组合操作符
 （1）concat()
 将多个被观察者所需要发送的事件组合在一个被观察者中，一起发送（即调用一个被观察者，多次调用onNext()方法）最多发送4个
 


 （2）concatArray()
 在concat()的基础上可以传无限个被观察者
 

（3）merge()
 在concat()的基础上，实现并行操作
 

7.功能操作符
 （1）subscribeOn（）
 确定上游事件所处线程
 （2）observeOn（）
 确定下游事件所处线程
 （3）参数
 

  • Schedulers.newThread() — 总是启用新线程，并在新线程中执行操作；多用于耗时操作
  • Schedulers.io() — 通常用于网络、读写文件等IO密集型的操作，行为模式和new Thread()差不多，只是IO的内部是一个无上限的线程池，可重用空闲的线程，更高效
  • AndroidSchedulers.mainThread() — Android的主线程；用于更新UI
  • Schedulers.computation() — 代表CPU计算密集型的操作
 

 

8.过滤操作符
 （1）filter()
 满足条件true则通过；不满足条件false过滤掉
 
 

9.条件操作符
 

10.自定义Observer
 

  1. 继承Observer
  2. 确定泛型类型
  3. 重写4个主要方法
  4. 使用模板设计模式
 

abstract class APIResponse(val context : Context)
    : Observer>{

    private var isShow = true

    //次构造函数 ->  主动控制Dialog显示
    constructor(context: Context,isShow : Boolean) : this(context){
        this.isShow = isShow
    }

    //模板设计模式
    abstract fun success(data : T ?)
    abstract fun failure(errorMsg: String ? )


    //订阅---最先调用
    override fun onSubscribe(d: Disposable) {
        // 弹出 加载框
        if (isShow) {
            LoadingDialog.show(context)
        }
    }

    //向下游---上游流下了的数据
    override fun onNext(t: LoginResponseWrapper) {

        if (t.data == null) {
            // 失败
            failure("登录失败了，请检查原因：msg:${t.errorMsg}")
        } else {
            // 成功
            success(t.data)
        }
    }

    //错误---上游流下了的错误
    override fun onError(e: Throwable) {
        // 取消加载
        LoadingDialog.cancel()

        failure(e.message)
    }

    //完成---传递数据完成后
    override fun onComplete() {
        // 取消加载
        LoadingDialog.cancel()
    }

}

 

11.对上下游所处线程进行封装
 

    private static  ObservableTransformer rxud() {
        return new ObservableTransformer() {
            @Override
            public ObservableSource apply(Observable upstream) {
                return  upstream.subscribeOn(Schedulers.io())     // 给上面代码分配异步线程
                        .observeOn(AndroidSchedulers.mainThread()) // 给下面代码分配主线程;
                        //hook
                        .map(new Function() {
                            @Override
                            public UD apply(UD ud) throws Exception {
                                Log.d(TAG, "apply: 我监听到你了，居然再执行");
                                return ud;
                            }
                        });
            }
        };
    }








转载请注明：文章转载自 www.mshxw.com















Java相关栏目本月热门文章












热门相关搜索






路由器设置
木托盘
宝塔面板
儿童python教程
心情低落
朋友圈
vim
双一流学科
专升本
我的学校
日记学校
西点培训学校
汽修学校
情书
化妆学校
塔沟武校
异形模板
西南大学排名
最精辟人生短句
6步教你追回被骗的钱
南昌大学排名
清朝十二帝
北京印刷学院排名
北方工业大学排名
北京航空航天大学排名
首都经济贸易大学排名
中国传媒大学排名
首都师范大学排名
中国地质大学(北京)排名
北京信息科技大学排名
中央民族大学排名
北京舞蹈学院排名
北京电影学院排名
中国戏曲学院排名
河北政法职业学院排名
河北经贸大学排名
天津中德应用技术大学排名
天津医学高等专科学校排名
天津美术学院排名
天津音乐学院排名
天津工业大学排名
北京工业大学耿丹学院排名
北京警察学院排名
天津科技大学排名
北京邮电大学(宏福校区)排名
北京网络职业学院排名
北京大学医学部排名
河北科技大学排名
河北地质大学排名
河北体育学院排名















学习工具


代数计算器


三角函数


解析几何


立体几何






知识解答


教育知识


百科知识


生活知识


常识知识






写作必备


作文大全


作文素材


句子大全



实用范文






关于我们


关于我们


联系我们


网站地图






 交流群

名师互学网交流群




名师互学网客服

名师互学网客服












名师互学网 版权所有 (c)2021-2022      ICP备案号：晋ICP备2021003244-6号
 








我们一直用心在做

关于我们
文章归档
网站地图
联系我们

版权所有 (c)2021-2022 MSHXW.COM


ICP备案号：晋ICP备2021003244-6号