首页
学习
活动
专区
工具
TVP
发布

RxJava系列五

这一章我们接着介绍组合操作符,这类operators可以同时处理多个Observable来创建我们所需要的Observable。组合操作符主要包含:等等。

Merge

将两个Observable发射的事件序列组合并成一个事件序列,就像是一个Observable发射的一样。你可以简单的将它理解为两个Obsrvable合并成了一个Observable,合并后的数据是无序的。

我们看下面的例子,一共有两个Observable:一个用来发送字母,另一个用来发送数字;现在我们需要两连个Observable发射的数据合并。

程序输出:

将多个Observable发射的事件序列组合并成一个事件序列,就像是一个Observable发射的一样。

!merge(Observable[])

StartWith

用于在源Observable发射的数据前插入数据。使用我们还可以在源Observable发射的数据前插入Iterable。官方示意图:

用于在源Observable发射的数据前插入另一个Observable发射的数据(这些数据会被插入到

源Observable发射数据的前面)。官方示意图:

Concat

)用于将多个obserbavle发射的的数据进行合并发射,concat严格按照顺序发射数据,前一个Observable没发射玩是不会发射后一个Observable的数据的。它和merge、startWitch和相似,不同之处在于:

merge:合并后发射的数据是无序的;

startWitch:只能在源Observable发射的数据前插入数据。

这里我们将前面Merge操作符的例子拿过来,并将操作符换成,然后我们看看执行结果:

程序输出:

Zip

用来合并两个Observable发射的数据项,根据Func2函数生成一个新的值并发射出去。当其中一个Observable发送数据结束或者出现异常后,另一个Observable也将停在发射数据。

和前面的例子一样,我们将操作符换成了:

程序输出:

CombineLatest

用于将两个Observale最近发射的数据已经Func2函数的规则进展组合。下面是官方提供的原理图:

下面这张图应该更容易理解:

程序输出:

SwitchOnNext

用来将一个发射多个小Observable的源Observable转化为一个Observable,然后发射这多个小Observable所发射的数据。如果一个小的Observable正在发射数据的时候,源Observable又发射出一个新的小Observable,则前一个Observable发射的数据会被抛弃,直接发射新

的小Observable所发射的数据。

结合下面的原理图大家应该很容易理解,我们可以看到下图中的黄色圆圈就被丢弃了。

Join

我们先介绍下join操作符的4个参数:

Observable:源Observable需要组合的Observable,这里我们姑且称之为目标Observable;

Func1:接收从源Observable发射来的数据,并返回一个Observable,这个Observable的声明周期决定了源Obsrvable发射出来的数据的有效期;

Func1:接收目标Observable发射来的数据,并返回一个Observable,这个Observable的声明周期决定了目标Obsrvable发射出来的数据的有效期;

Func2:接收从源Observable和目标Observable发射出来的数据,并将这两个数据组合后返回。

所以Join操作符的语法结构大致是这样的:

join操作符的效果类似于排列组合,把第一个数据源A作为基座窗口,他根据自己的节奏不断发射数据元素,第二个数据源B,每发射一个数据,我们都把它和第一个数据源A中已经发射的数据进行一对一匹配;举例来说,如果某一时刻B发射了一个数据“B”,此时A已经发射了0,1,2,3共四个数据,那么我们的合并操作就会把“B”依次与0,1,2,3配对,得到四组数据:

再看看下面的图是不是好理解了呢?!

读懂了上面的文字,我们再来写段代码加深理解。

程序输出:

通过转换操作符、过滤操作符、组合操作符三个篇幅将RxJava主要的操作符也介绍的七七八八了。更多操作符的介绍建议大家去查阅官方文档,并自己动手实践一下。这一系列的文章也会持续更新,欢迎大家保持关注!:)

Demo源码地址:https://github.com/BaronZ88/HelloRxJava

知乎专栏:https://zhuanlan.zhihu.com/baron

GitHub:https://github.com/BaronZ88

  • 发表于:
  • 原文链接http://kuaibao.qq.com/s/20171231G0IUI900?refer=cp_1026
  • 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 cloudcommunity@tencent.com 删除。

扫码

添加站长 进交流群

领取专属 10元无门槛券

私享最新 技术干货

扫码加入开发者社群
领券