学习指南：操作符
1.数学类：必须等上游完结才给下游传递唯一数据；
（1）count()：统计上游Observable对象吐出的所有数据个数；
（2）max()/min()：可接受比较函数做参数；
（3）reduce(fn(acc，current)，初始值)
- fn是规约函数，acc表示当前的累积值，current表示当前Observable对象吐出的值；
- 初始值：累积值的初始值；
2.条件布尔类操作符：
（1）every(fn)：上游的Observable对象吐出的每一个数据都会被fn()检验，若所有数据的判定结果都是true，则吐出true，否则一旦不满足判定条件，就返回false并完结；
（2）find(fn)：返回满足fn判定条件的第一个元素，若没有满足判定条件的元素则返回undefined后完结；
（3）findIndex(fn)：返回满足fn判定条件的第一个元素的序号，若没有满足条件的元素则返回-1后完结；
（4）isEmpty()：检查上游Observable对象是否是没有吐出任何数据就完结的Observable对象；
3.过滤类操作符：判定数据流对每个数据是否有资格进入下游；
（1）filter()：产生数据的时机与上游是一致的，当上游产生数据时，只要满足判定条件，就会立刻被同步传给下游；
（2）first()：
- 无参数：找到上游Observable对象吐出的第一个数据就完结；
- 有参数：
- 参数1：判定函数fn()
- 参数2：函数(满足条件的值，序号)对满足判定条件的数据进行操作；
- 参数3：当上游没有满足判定条件时传递给下游对象的默认值，若不设置则会传一个EmptyError；
const first$ = s$.first(
x => x < 0, //判定条件是找出负数；
f => f, // 对找到的负数做相应的处理；
-1 //若没有负数则返回-1；
)
（3）last()：找出Observable对象中满足判定条件的最后一个数据；因此last要等Observable对象完结时才吐出数据；
（4）take(count)：限定从上游Observable对象取出的数据量；
（5）takeCountWhile(count, fn)：对上游Observable的每个数据用fn判定，立刻传给take，只要取到了count个数据即完结；
（6）**takeUntil(notifier吐出一个数据或完结，上游通往下游的通道被关闭；
const s$ = Observbale.interval(1000);
const n$ = Observable.timer(2500);
const takeUntil$ = s$.takeUntil(n$); //上游Observable对象每间隔一秒吐出一个递增的数据，在2.5s之后完结，因为n$有了值；
（7）skip(count)：忽略上游Observable对象的前count个数据，从第count+1个数据开始，上下游Observable对象保持一致了；若上游吐出的数据不够count个，则skip产生的Observable对象就会在上游完结时立刻完结；
3.转化数据流
（1）map()
（2）switchMap()：同一时间内只维护一个内部Observable对象；
