常用操作符:
- 创建: just 、create 、fromArray 、fromIterator 创建
- 订阅: subscribe
- 指定被观察者的处理线程: subscribeOn
- 指定订阅者的执行线程: observeOn
- 延迟发送: delay
- 观察者和被观察者的 类似声明周期的操作符: do...
好,上方的是我们常用的操作符,下面详细分一下类,方便大家记忆~~~
创建Observable类型的操作符
- create
- just
- fromArray
- fromIterator
定时、连续创建Observable 类型的操作符
- timer 在发送完事件之后再发送一个值为0的事件,一般用作确认
- defer 当订阅者订阅时 Observable 才发送事件
- interval 在指定延迟时间后,每隔指定时间,连续发送事件,事件值递增,发送的事件无限
- intervalRange 同上,只不过在上边的基础上制定了事件的范围,从哪开始,连续发送多少个
- range 同 intervalRange ,区别是不用指定间隔时间,直接连续发送
- rangeLong 同 range,区别是支持 Long 类型的参数
转换类型的操作符
- map 把某一类型事件转化成另外一个类型
- flatMap 把某一类型事件转化成一个Observable对象 无序
- concatMap 同上,但有序跟原来顺序一致
- buffer 缓存,然后进行发送
合并Observable的操作符
- concat/concatArray 串行
- merge/mergeArray 并行
- concatDelayError 延迟错误
- mergeDelayError 延迟错误
合并Observable发送出的事件 的操作符
- zip 合并,合并之后的数量为事件少的那个数量
- reduce 通过自定义的合并的方法把多个事件转化成一个事件,然后发送
- collect 把事件添加到集合中,然后发送
- combineLatest 合并最新的
- combineLatestDelayError 延迟错误
- count 计数
- startWith 开始发送事件前 添加一个
- startWithArray 添加多个
取消事件
- disposable.dispose(); 清空某个Observable的事件
- compositeDisposable.add()+compositeDisposable.clear() 清空全部事件