rxjava 常用操作符

创建操作

create

创建一个Observable

timer

延时发送

interval

循环发送

from

接受数组，返回一个按参数列表顺序发射这些数据的Observable。

just

just函数，它接受一至九个参数，返回一个按参数列表顺序发射这些数据的Observable。

变换操作

map

操作符对原始Observable发射的每一项数据应用一个你选择的函数，然后返回一个发射这些结果。

flatMap

flatMap()接收一个Observable的输出作为输入，然后作为一个新的Observable再发射。

scan

一个累加器函数，操作符对原始Observable发射的第一项数据应用一个函数，然后将那个函数的结果作为自己的第一项数据发射。

GroupBy

按照指定的规则来分组元素。

过滤操作

filter

过滤数据，观测序列中只有通过的数据才会被发射。

take()

只发射设定的前几个元素

takeLast()

只发射设定的后几个元素

frist

只发射第一个元素

last

只发射最后一个元素

skip

跳过设定的前几个元素

skipLast

跳过设定的最后几个元素

distinct

去除重复元素

ElementAt

仅从一个序列中发射第n个元素然后就完成了，这里是从0开始计的。

Sample

定期发射Observable最近发射的数据项

合并操作

merge

合并多个Observables的发射物，多输入，单输

zip

合并两个或者多个Observables发射出的数据项，根据指定的函数Func2变换它们，并发射一个新值。