Operators操作符

操作符（Operators）：其实质是函数式编程中的高阶函数，是对响应式编程的各个过程拆分封装后的产物。以便于我们操作数据流。

按照其作用具体可分为以下几类：

创建：创建一个可观察对象Observable并发射数据

过滤：从Observable发射的数据中取出特定的值

变换：对Observable发射的数据执行变换操作

组合：组合多个Observable,例如：{1,2,3}+{4,5,6}-->{1,2,3,4,5,6}

聚合：聚合多个Observable，例如：{1,2,3}+{4,5,6}-->{[1,4],[2,5],[3,6]}

下面对一些常用的操作符做一下介绍（后面的章节中，会做全面汇总）

创建操作：

create:基础创建操作符

just:创建一个Observable，可接受一个或多个参数，将每个参数逐一发送

fromArray:创建一个Observable，接受一个数组，并将数组中的数据逐一发送

fromIterable：创建一个Observable，接受一个可迭代对象，并将可迭代对象中的数据逐一发送

range：创建一个Observable，发送一个范围内的整数序列

过滤操作（filter与distinct）：

filter：filter使用Predicate 函数接口传入条件值，来判断Observable发射的每一个值是否满足这个条件，如果满足，则继续向下传递，如果不满足，则过滤掉。

如下图：

distinct:过滤掉重复的数据项，过滤规则为：只允许还没有发射过的数据项通过。

如下图：

链接使用

所有的操作符均可以链接配合使用，共同对结果起作用

先对数据序列去重{1,1,2,3,1,2,2,4,5}，然后在筛选出偶数

变换操作（map与flatMap）

map:对Observable发射的每一项数据应用一个函数，执行变换操作

map操作符，需要接收一个函数接口Function<T,R>的实例化对象，实现接口内R apply(T t)的方法，在此方法中可以对接收到的数据t进行变换后返回。

如下图：

flatMap:将一个发射数据的Observable变换为多个Observable，然后将多个Observable发射的数据合并到一个Observable中进行发射

如下图：

首先，用just操作符，发射三个数组，通过flatMap变换，将每个数组中的元素用操作符fromArray取出后逐一发射

扩展：

timer()：用于创建Observable，延迟发送一次。

interval()：用于创建Observable，跟TimerTask类似，用于周期性发送。

delay()：用于事件流中，可以延迟发送事件流中的某一次发送。