Rxjava2入门教程三:Operators操作符
作者:互联网
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,可接受一个或多个参数,将每个参数逐一发送
Observable.just("hello world");//发送一个字符串"hello world"
Observable.just(1,2,3,4);//逐一发送1,2,3,4这四个整数
fromArray:创建一个Observable,接受一个数组,并将数组中的数据逐一发送
fromIterable:</b>创建一个Observable,接受一个可迭代对象,并将可迭代对象中的数据逐一发送
range:</b>创建一个Observable,发送一个范围内的整数序列
Observable.range(1,10);//从1开始以步长1递增发送10个数据
运行如下代码:
demo1_range.jpg
控制台打印:
0
1
2
3
4
过滤操作(filter与distinct):
filter:filter使用Predicate 函数接口传入条件值,来判断Observable发射的每一个值是否满足这个条件,如果满足,则继续向下传递,如果不满足,则过滤掉。
如下图:
05F271FEB0494D3C85FA622419DD943A.jpg
运行如下代码:
demo2_filter.jpg
通过rang操作符发射整数序列0~10;然后通过filter过滤能被3整除的数,控制台打印如下;
0
3
6
9
distinct:过滤掉重复的数据项,过滤规则为:只允许还没有发射过的数据项通过。
如下图:
2DFB371B1F314B90B8E7A55966B1EC5D.jpg
运行如下代码:
demo3_distinct.jpg
通过just操作符,发射数据序列{1,1,2,3,1,2,2,4,5};然后通过distinct过滤去重,运行结果如下:
1
2
3
4
5
链接使用
所有的操作符均可以链接配合使用,共同对结果起作用
先对数据序列去重{1,1,2,3,1,2,2,4,5},然后在筛选出偶数
demo4_distinct_filter.jpg
运行结果如下;
2
4
变换操作(map与flatMap)
map:对Observable发射的每一项数据应用一个函数,执行变换操作
map操作符,需要接收一个函数接口Function<T,R>的实例化对象,实现接口内R apply(T t)的方法,在此方法中可以对接收到的数据t进行变换后返回。
如下图:
0449AFF58A654A8282737BE31F3226E7.jpg
运行如下代码:
demo5_map.jpg
在方法apply中,对Observable发射过来的数字integer执行了以下变换integer+"^2 = "+integer*intege后返回。
运行结果如下:
0^2 = 0
1^2 = 1
2^2 = 4
3^2 = 9
4^2 = 16
flatMap:将一个发射数据的Observable变换为多个Observable,然后将多个Observable发射的数据合并到一个Observable中进行发射
如下图:
BD6A82E54E6648BB8A3FD66AFA19EDBF.jpg
运行如下代码:
demo6_flatMap.jpg
首先,用just操作符,发射三个数组,通过flatMap变换,将每个数组中的元素用操作符fromArray取出后逐一发射
最后观察者接收数据如下;
1
2
3
4
5
6
7
8
9
组合操作(mergeWith与concatWith)
mergeWith:合并多个Observable发射的数据,可能会让Observable发射的数据交错。
如下图:
D81F3936DC1E46DFB6E375C2B14B0DF5.jpg
运行如下代码:
demo7_mergeWith.jpg
一个Observable用just发送数据序列1,2,3,4,5,另一个Observable用fromArray逐一发送数组中的数据5,6,7,8,9,然后用mergeWith将两者组合,运行如下
1
2
3
4
5
5
6
7
8
9
concatWith:同mergeWith一样,用以合并多个Observable发射的数据,但是concatWith不会让Observable发射的数据交错。
如下图:
concatWith.jpg
运行如下代码:
demo8_concatWith.jpg
一个Observable用just发送数据序列1.2.3.4,5,另一个Observable用fromArray逐一发送数组中的数据5,6,7,8,9,然后用concatWith将两者组合,运行如下
1
2
3
4
5
5
6
7
8
9
聚合操作(zipWith)
zipWith:将多个Obversable发射的数据,通过一个函数BiFunction对对应位置的数据处理后放到一个新的Observable中发射,所发射的数据个数与最少的Observabel中的一样多。
定义一个函数:
344FA00396BB4C5EA85D004F9ADEDAC0.jpg
聚合如下:
CDA3BBC425CE4097B4BE45B923E526B1.jpg
代码如下:
demo9_zipWith.jpg
zipWith需要接收两个参数,
一个是可观察对象,
另一个是聚合函数接口BiFunction,这个接口有三个泛型,分别为第一个可观察对象发射的数据类型,第二个可观察对象发射的数据类型,经过聚合函数apply处理后返回的数据类型
代码运行结果为;
1红娃
2橙娃
3黄娃
4绿娃
5青娃
6蓝娃
7紫娃
以上的操作符均可以链接使用,下面的代码链接了本节中的所有操作符
demo10_link_all_operators.jpg
运行结果如下;
3:红娃
4:橙娃
1:黄娃
2:绿娃
标签:Observable,Operators,入门教程,jpg,如下,操作符,发射,Rxjava2,数据 来源: https://blog.csdn.net/l848168/article/details/104821835