RxJava 特点
异步数据处理库,轻量级框架,支持java 8, lambda,支持java6,Android 2.3,支持异步和同步,扩展的模式,观察者模式
RxAndroid
是Rxjava对android的一个扩展
Schedulers(调度器)
RxJava 观察者模式四大要素:
1 observable被观察者 2observer观察者 3subscribe(订阅) 4 事件
oncomplete和onError只能回调一个
操作符的分类
Create创建操作符;
Just是create简写;
From里面可以放 数组,列表等类型;
Defer在使用对象的时候才创建,其他不是;
Empty空的没有数据的,直接回调oncmoplete; never不回调;throw错误的回调
Interval 设置好的间隔时间进行发射
Range (n,m) 范围,从n开始到m
Repeat(2) 重复2次执行
Start Timer
交换类型操作符:
map, FlatMap,groupBy对数据分组,buffer ,scan,
过滤性操作符
Debounce 在一定的时间没有操作,发送到观察者; distinct除去列表中重复数据
ElementAt 制定位置 ;Filter 按照指定规则过滤,指定条件可以自定义
First 列表数据第一位数据 ; IgnoreElements 直接回调onComplete,出错Erro
Last 列表最后一个数据; Sample 取样,
Skip 跳跃制定数据 ; SkipLast跳过数据列表最后几项
Take 只取前面数据 ; TakeLast取列表最后的数据