2017/12/5 RxJava2.0实用操作符总结及原理简析
https://mp.weixin.qq.com/s/OJCEyH1gJ-JiRIDC3LLi3w 3/11
的方式，现在我们就来详细分析一下构成宝石图的各个主要元素。
首先，我们有必要回顾一下Rx中的几个主要的基类
io . reactivex . Flowable : 事件源(0..N个元素), 支持 Reactive-Streams and 背压
io . reactivex . Observable :事件源(0..N个元素), 不支持背压
io . reactivex . Single : 仅发射一个元素或产生error的事件源，
io . reactivex . Completable : 不发射任何元素，只产生completion或error的事件源
io . reactivex . Maybe : 不发射任何元素，或只发射一个元素，或产生error的事件源
Subject : 既是事件源，也是事件接受者 可以看到Rx中最重要的概念就是 事件源 了，基本上所有的操作符都是针对事件源来进行一些转换、组合等操作，而
我们最常用的事件源就是 Observable 了。
本文中我们就以 Observable 事件源为例来讲解Rx的操作符， Observable 发射的事件我们统一称之为item。首先我们需要详细了解一下宝石图中
各个图像元素的含义：
—> ： Observable 的时间线，从左至右流动
★ ：星星、圆、方块等表示 Observable 发射的item
| ：时间线最后的小竖线表示 Observable 的事件流已经成功发射完毕了
X ：时间线最后的X符合表示由于某种原因 Observable 非正常终止发射，产生了error
上面几种元素组合在一起代表一个完整的 Observable ，也可以称为源 Observable
--> 方向朝下的虚线箭头表示以及中间的长方框表示正在对上面的源 Observable 进行某种转换。长方框里的文字展示了转换的性质。下面的
Observable 是对上面的源 Observable 转换后的结果。
掌握了宝石图的含义，我们就可以根据某个操作符的宝石图快速理解这个操作符了。举几个例子：
1. map 可以看到，这幅图表达的意思是一个源
Observable 先后发射了1、2、3的三个item，而经过 map 操作符一转换，就变成了一个发射了10、20、30三个item的新的 Observable 。描述操
作符的长方框中也清楚的说明了该 map 操作符进行了何种具体的转换操作（图中的10*x只是一个例子，这个具体的转换函数是可以自定义
的）。
于是，我们就很快速地理解了 map 操作符的含义和用法，简单来讲，它就是通过一个函数将一个 Observable 发射的item逐个进行某种转换。
示例代码：
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(@NonNull ObservableEmitter<Integer> e) throws Exception {
e.onNext(1);
e.onNext(2);
e.onNext(3);
}
}).map(new Function<Integer, Integer>() {
@Override
public Integer apply(@NonNull Integer integer) throws Exception {
return integer * 10;
}
}).subscribe(new Consumer<Integer>() {
@Override
public void accept(@NonNull Integer result) throws Exception {
Log.i(TAG, "accept : " + result +"\n" );
}
});
输出结果：
剩余10页未读，继续阅读
tmepri
- 粉丝: 1
- 资源: 27
我的内容管理
展开
最新资源
- C++标准程序库：权威指南
- Java解惑：奇数判断误区与改进方法
- C++编程必读：20种设计模式详解与实战
- LM3S8962微控制器数据手册
- 51单片机C语言实战教程：从入门到精通
- Spring3.0权威指南：JavaEE6实战
- Win32多线程程序设计详解
- Lucene2.9.1开发全攻略：从环境配置到索引创建
- 内存虚拟硬盘技术：提升电脑速度的秘密武器
- Java操作数据库：保存与显示图片到数据库及页面
- ISO14001：2004环境管理体系要求详解
- ShopExV4.8二次开发详解
- 企业形象与产品推广一站式网站建设技术方案揭秘
- Shopex二次开发：触发器与控制器重定向技术详解
- FPGA开发实战指南：创新设计与进阶技巧
- ShopExV4.8二次开发入门：解决升级问题与功能扩展
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
