创建操作符
复杂数据遍历
just
fromArray
fromIterable
range
定时任务
interval
intervalRange
嵌套回调异步事件
create
延迟任务
defer
timer
变换操作符
变换
map
flatMap
concatMap
合并操作符
组合多个被观察者，合并事件
concatArray(发送事件--串行)
concatDelayError
megerArray(发送事件--并行)
megerArrayDelayError
组合多个被观察者，合并为一个被观察者
zip
combineLatest
发送事件前追加其他事件
startWithArray
组合多个事件为一个事件
reduce
collect
汇总发送事件数量
count
过滤操作符
指定过滤条件，过滤需要的事件/数据
filter
过滤指定类型的事件/数据
ofType
过滤条件不满足的事件/数据
skip
过滤掉重复的事件/数据
distinct
distinctUntilChanged
按时间或者数量过滤事件/数据
take
过滤指定位置的事件
elementAt
按事件段过滤事件
throttleFirst
throttleLast
条件操作符
判断所有事件是否满足
all
发送的事件判断条件不满足时，就会终止后续事件接收
takeWhile
发送的事件判断条件不满足时，才接收后续的事件
skipWhile
过滤事件(同filter)
takeUntil
接收判断条件满足之外的事件
skipUntil
判断2个被观察者发生的事件是否一样
sequenceEqual
判断发送的数据里面是否包含指定数据
contains
判断发送的数据是否为空
isEmpty
多个被观察者，只接收"第一个成功发送数据的被观察者"
amb
其他功能操作符
常用的do系列操作符
doOnEach
doOnSubscribe
doOnNext
doAfterNext
doOnComplete
doOnErro
错误/异常处理
抓捕异常并反馈特殊的结果&正常终止
onErrorRetuturn
抓捕异常并返回一个新的事件
onErrorResumeNext
异常重试
retry
事件重发
repeat
repeatWhen
repeatUntil
延迟发送被观察者的事件
delay
发送事件超时处理
timeout