编程语言
首页 > 编程语言> > Rxjava2入门教程三:Operators操作符

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