RxJava-飞

 

RxJava概述RxJava 是一种响应式编程，来创建基于事件的异步操作库。基于事件流的链式调用、逻辑清晰简洁。RxJava 我的理解是将事件从起点（上游）流向终点（下游），中间有很多卡片对数据进操作并传递，每个卡片获取上(jk是什么意思是什么？JK是“じょしこうこうせい ”（女子高校生）罗马音 jyoshi koukousei 的简写(取其中“J”和“K”)，通常指日本女高中生；JK也是ACGN次文化中的萌属性之一。)一个卡片传递下来的结果然后对事件进行处理然后将结果传递给下一个卡片，这样事件就从起点通过卡片一次次传递直到流向终点。RxJava观察者模式传统观察者是一个被观察者多过观察者，当被观察者发生改变时候及时通知所有观察者RXjava是一个观察者多个被观察者，被观察者像链条一样串起来，数据在被观察者之间朝着一个方向传递，直到传递给观察者 。RxJava原理理解

被观察者通过订阅将事件按顺序依次传递给观察者，

image.png

//RxAndroid中包含RxJava的内容，只引入RxAndroid还是会报错dependencies {    ......    compile 'io.reactivex.rxjava2:rxjava:2.1.3'    compile 'io.reactivex.rxjava2:rxandroid:2.0.1'}

image.png创建Observer（观察者）

        Observer<Integer> observer = new Observer<Integer>() {             // 观察者接收事件前  ，当 Observable 被订阅时，观察者onSubscribe方法会自动被调用             @Override            public void onSubscribe(Disposable d) {                Log.d(TAG, "开始采用subscribe连接");            }            // 当被观察者生产Next事件             @Override            public void onNext(Integer value) {                Log.d(TAG, "对Next事件作出响应" + value);            }            // 当被观察者生产Error事件             @Override            public void onError(Throwable e) {                Log.d(TAG, "对Error事件作出响应");            }            // 当被观察者生产Complete事件             @Override            public void onComplete() {                Log.d(TAG, "对Complete事件作出响应");            }        };

       //Subscriber类 = RxJava 内置的一个实现了 Observer 的抽象类，对 Observer 接口进行了扩展        Subscriber<Integer> subscriber = new Subscriber<Integer>() {           // 观察者接收事件前 ，当 Observable 被订阅时，观察者onSubscribe方法会自动被调用             @Override            public void onSubscribe(Disposable d) {                 Log.d(TAG, "开始采用subscribe连接");            }            // 当被观察者生产Next事件             @Override            public void onNext(Integer value) {                Log.d(TAG, "对Next事件作出响应" + value);            }            // 当被观察者生产Error事件             @Override            public void onError(Throwable e) {                Log.d(TAG, "对Error事件作出响应");            }            // 当被观察者生产Complete事件             @Override            public void onComplete() {                Log.d(TAG, "对Complete事件作出响应");            }        };

Subscriber 抽象类与Observer 接口的区别

二者基本使用方式一致（在RxJava的subscribe过程中，Observer会先被转换成Subscriber再使用）Subscriber抽象类对 Observer 接口进行了扩展，新增了两个方法：
1. onStart()：在还未响应事件前调用，用于做一些初始化工作，他是在subscribe 所在的线程调用，不能切换线程，所以不能进行界面UI更新比如弹框这些。
2. unsubscribe()：用于取消订阅。在该方法被调用后，观察者将不再接收响应事件，比如在onStop方法中可以调用此方法结束订阅。调用该方法前，先使用 isUnsubscribed() 判断状态，确定被观察者Observable是否还持有观察者Subscriber的引用。创建 Observable （被观察者）

        Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {            @Override            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {                // 通过 ObservableEmitter类对象产生事件并通知观察者                // ObservableEmitter：定义需要发送的事件 & 向观察者发送事件                                     emitter.onNext(1);                emitter.onComplete();            }        });

RxJava 提供了其他方法用于 创建被观察者对象Observable

// 方法1：just(T...)：直接将传入的参数依次发送出来  Observable observable = Observable.just("A", "B", "C");  // 将会依次调用：  // onNext("A");  // onNext("B");  // onNext("C");  // onCompleted();// 方法2：fromArray(T[]) / from(Iterable<? extends T>) : 将传入的数组 / Iterable 拆分成具体对象后，依次发送出来  String[] words = {"A", "B", "C"};  Observable observable = Observable.fromArray(words);  // 将会依次调用：  // onNext("A");  // onNext("B");  // onNext("C");  // onCompleted();

以上两种方法创建出来的观察者都是继承Observable，比如ObservableCreate、ObservableFromArray、ObservableMap...，

public interface ObservableSource<T> {    void subscribe(@NonNull Observer<? super T> observer);}--------------------------------------------------------------------------------------------------------public abstract class Observable<T> implements Observ


扫码加微信详细咨询太和智慧养老产品和平台服务！ 

		
 
            
            
 
 
 





版权声明： 
 
---------------------------------------------------------------


所有信息来源于互联网,本文的版权归原作者所有，不代表本网观点和立场。

 
本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，请发送邮件至 81480447@qq.com 举报，一经查实，本站将立刻删除。 





扫码加微信详细咨询太和智慧养老产品和平台服务！ 


  
		
 
		

				
养老资讯
                         
	
高考英语答题技巧（高中英
 
教师业务学习心得（领导不
 
小学你的梦想是什么，初中
 
女神节朋友圈文案怎么发？
 
有哪些会让你感到凄凉、悲
 
什么样的人能永远快乐？物
 
六一儿童节趣味活动（马上
 
互联网创新创业点子（工厂
 
公务员考试题库大全（公务
 
你对班主任的工作有哪些认
 
人与自然的关系是怎样的对
 
疫情时期在家待着，每天都
 
为什么成功的人看起来那么
 
做广告灯箱业务员，应该从
 
看完湿得最厉害的文案（迄
 
给高三学生的暖心话（有没
 
后进生转化案例10篇（有
 
什么心态的人会怂恿别人哗
 
信贷客户经理（当一名银行
 
如何评价由蒋欣、李光洁、
 
   
	                 
	
怎样看待大学每天的跑操？
 
快乐原来如此简单（什么是
 
零分作文被北大录取（如果
 
为什么小孩子要摆满月酒？
 
走进毛泽东观后感（“毛瓷
 
曾经沧海难为水（“曾经沧
 
桃花的花期有多长？春天来
 
教师节祝福图片（教师节，
 
有哪些开头恐怖结尾搞笑的
 
你怎么看乌克兰总统选举遭
 
公司不批离职申请，直接走
 
关于螃蟹的神秘面纱你知道
 
清明祭祖的意义在哪里？清
 
成长是一个怎样的过程？你
 
科普文章范文格式（你觉得
 
我的朋友他的妻子电影（看
 
如何评价《蜘蛛侠：英雄归
 
女娲补天教案（怎样看女娲
 
暑假生活图片（在高二的暑
 
古代有哪些痴情人士？世界
 
   
		


助老机构介绍
                         
	
兴华街道办事处(市政路)
 
满洲里市兴华街道办事处司法所
 
满洲里市兴华街道办事处劳动保障事务所
 
兴华街道办事处人民调节委员会
 
中共兴华街道办事处工作委员会
 
小树音乐琴行
 
优智教育
 
盼盼超烁驻呼伦贝尔办事处
 
呼伦贝尔市宇华经贸有限责任公司
 
华通图文广告设计部
 
博诚装饰有限公司
 
满洲里市兴华街道办事处劳动保障事务所
 
海潮电脑屋
 
华春堂大药房
 
停车场(兴华社区卫生服务站西南)
 
扎兰屯市中和镇委
 
中和镇人民政府
 
扎兰屯市人民法院中和人民法庭
 
中和派出所
 
福兴村村委会
  
   
                         
	
中共福兴村支部委员会
 
中和第一中学
 
石本羊绒制品有限公司中和分公司
 
呼伦贝尔市天悦新能源设备销售有限公司
 
德良酒业
 
中国联通(中和营业厅)
 
中国邮政(中和邮政支局)
 
广文婚纱摄影
 
中国体育彩票中和竞彩店
 
亮仔酒吧
 
维心药店(中和镇店)
 
中和中心卫生院
 
益民堂大药房(中和大街)
 
鸿利药店(中和大街)
 
中国信合(中和信用社)
 
中国邮政储蓄银行(扎兰屯市中和镇营业所)
 
成吉思汗广场
 
成吉思汗庙
 
成吉思汗大营
 
成吉思汗广场-喷泉