| 操作符 | 作用 |
|---|---|
| map | 对数据流的类型进行转换 |
| flatMap | 对数据流的类型进行包装成另一个数据流 |
| concatMap | 类似FlatMap()操作符, 区别在于：concatMap是有序的，flatMap是无序的 |
| concatMapDelayError | 与concatMap作用相同，只是将过程发送的所有错误延迟到最后处理 |
| concatMapCompletable | 作用于Flowable、Observable。与contactMap类似，不过应用于函数后，返回的是CompletableSource |
| concatMapCompletableDelayError | 与concatMapCompletable作用相同，只是将过程发送的所有错误延迟到最后处理 |
| scan | 对上一轮处理过后的数据流进行函数处理 |
| groupBy | 对所有的数据流进行分组 |
| buffer | 缓存发射的数据流到一定数量，随后发射出数据流集合 |
| window | 缓存发射的数据流到一定数量，随后发射出新的事件流 |
| cast | 作用于Flowable、Observable、Maybe、Single。将数据元素转型成其他类型,转型失败会抛出异常 |
| flattenAsFlowable & flattenAsObservable | 作用于Maybe、Single，将其转化为Flowable，或Observable |
网友评论