前言：

昨天的两篇介绍了 RxJava 的创建类操作符和延时类操作符，今天笔者记录一下转换类操作符，不太监了，开始记笔记。对了具体不太清楚转换过程的可以去拜读这位大佬 Season_zlc 关于 map 等操作符的介绍链接为：给初学者的RxJava2.0教程(三) 。

正文：

1、map 操作符

1)、作用

将观察者发射的数据从发射类型转换为其它类型
多应用于数据类型转换

2)、代码

 /***  map 操作符*/private void mapMethod() {Observable.create(new ObservableOnSubscribe<Integer>() {@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {emitter.onNext(111);emitter.onNext(222);emitter.onNext(333);emitter.onNext(444);}}).map(new Function<Integer, String>() {@Overridepublic String apply(Integer integer) throws Exception {return "将 Integer 类型数据转换为 String 类型数据："+integer;}}).subscribe(new Observer<String>() {@Overridepublic void onSubscribe(Disposable d) {logDUtils("onSubscribe:");}@Overridepublic void onNext(String s) {logDUtils("onNext:" + s);}@Overridepublic void onError(Throwable e) {logDUtils("onError:"+e.getMessage());}@Overridepublic void onComplete() {logDUtils("onComplete:");}});}

3）、效果

被观察对象在 map 操作符内进行相应的转换在观察者对象得到新的数据类型

2、FlatMap 操作符

1）、作用

将被观察者发射的指定类型的一个数据转换或拆分为多个类型数据发射给观察者的；
拆分之后的数据被重组为一个新的被观察者发射给观察者；
新组建的被观察者为无序。

2）、代码

 /*** FlatMap 操作符*/@SuppressLint("CheckResult")private void flatMapMethod() {Observable.create(new ObservableOnSubscribe<Integer>() {@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {emitter.onNext(111);emitter.onNext(222);emitter.onNext(333);emitter.onNext(444);}}).flatMap(new Function<Integer, ObservableSource<String>>() {@Overridepublic ObservableSource<String> apply(Integer integer) throws Exception {List<String> list = new ArrayList<>();for (int i = 0; i < 3; i++) {list.add("从被观察者接收到的数据" + integer);}//为了验证 无序性 添加了 100 毫秒 的延迟操作return Observable.fromIterable(list).delay(100, TimeUnit.MILLISECONDS);}}).subscribe(new Consumer<String>() {@Overridepublic void accept(String s) throws Exception {logDUtils("accept:" + s);}});}

3)、效果

3、concatMap 操作符

1）、作用

作用与 FlatMap 操作符相同，只是保证了有序性

2）、代码

  /*** ConcatMap 操作符*/@SuppressLint("CheckResult")private void concatMapMethod() {Observable.create(new ObservableOnSubscribe<Integer>() {@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {emitter.onNext(111);emitter.onNext(222);emitter.onNext(333);emitter.onNext(444);}}).concatMap(new Function<Integer, ObservableSource<String>>() {@Overridepublic ObservableSource<String> apply(Integer integer) throws Exception {List<String> list = new ArrayList<>();for (int i = 0; i < 3; i++) {list.add("从被观察者接收到的数据" + integer);}//为了验证 有序性 添加了 100 毫秒 的延迟操作return Observable.fromIterable(list).delay(100, TimeUnit.MILLISECONDS);}}).subscribe(new Consumer<String>() {@Overridepublic void accept(String s) throws Exception {logDUtils("accept:" + s);}});}

3)、效果

4、buffer 操作符

1)、作用

从被观察者内拿到指定长度的数据缓存到缓存区内打包一起发射给观察者，当发射数据不够指定长度则不再进行缓存。

2)、代码

/*** Buffer 操作符*/@SuppressLint("CheckResult")private void bufferMethod() {Observable.create(new ObservableOnSubscribe<Integer>() {@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {emitter.onNext(111);emitter.onNext(111);emitter.onNext(222);emitter.onNext(222);emitter.onNext(333);emitter.onNext(333);emitter.onNext(444);emitter.onNext(444);}}).buffer(3).subscribe(new Consumer<List<Integer>>() {@Overridepublic void accept(List<Integer> integers) throws Exception {logDUtils("accept:" + integers);}});}

3)、效果

buffer 操作符还有另一个常用的方法

//参数：缓存数量   步长：从第一个还是计算，指定数据数量之后 再次进行缓存  可以取样用
public final Observable<List<T>> buffer(int count, int skip)

代码

 /*** Buffer 操作符*/@SuppressLint("CheckResult")private void bufferMethod() {Observable.create(new ObservableOnSubscribe<Integer>() {@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {emitter.onNext(111);emitter.onNext(111);emitter.onNext(222);emitter.onNext(222);emitter.onNext(333);emitter.onNext(333);emitter.onNext(444);emitter.onNext(444);}}).buffer(2,3).subscribe(new Consumer<List<Integer>>() {@Overridepublic void accept(List<Integer> integers) throws Exception {logDUtils("accept:" + integers);}});}

效果

初识RxJava（三）转换类操作符相关推荐

RxJava进阶一（创建类操作符）
RxJava进阶一(创建类操作符) RxJava进阶二(转换类操作符) RxJava进阶三(过滤类操作符) RxJava进阶四(组合类操作符) 前面已经对RxJava原理进行介绍,相信大家对于RXJa ...
RxJava系列4(过滤操作符)
前面一篇文章中我们介绍了转换类操作符,那么这一章我们就来介绍下过滤类的操作符.顾名思义,这类operators主要用于对事件数据的筛选过滤,只返回满足我们条件的数据.过滤类操作符主要包含: Filte ...
大话RxJava：一、初识RxJava与基本运用
转: http://www.jianshu.com/p/856297523728 .subscribeOn(Schedulers.io()) // 指定subscribe()发生在IO线程 ---& ...
RxJava使用说明5-组合操作符
RxJava使用说明1-简介 RxJava使用说明2-基本概念及使用介绍 RxJava使用说明3-转换操作符 RxJava使用说明4-过滤操作符 RxJava使用说明5-组合操作符 RxJava2更新 ...
C++ Primer 学习笔记_62_重载操作符与转换 --调用操作符和函数对象
重载操作符与转换 --调用操作符和函数对象引言: 能够为类类型的对象重载函数调用操作符:一般为表示操作的类重载调用操作符! struct absInt {int operator() (int va ...
python自学第8天字典_孤荷凌寒自学python第十一天初识Python的字典类
孤荷凌寒自学python第十一天初识Python的字典类 (完整学习过程屏幕记录视频地址在文末,手写笔记在文末) Python的字典其实是一张二维对照表下面举例说明: 键名Key 姓名性别身高 ...
CImg库中CImg,CImgList,CImgDisplay三个类的介绍
转自:http://www.cppprog.com/2009/0426/108.html 本文简单介绍了CImg库中的三个大类:CImg,CImgList,CImgDisplay.然后给出了让CImg ...
RTKLIB专题学习(七)---精密单点定位实现初识（三）
RTKLIB专题学习(七)-精密单点定位实现初识(三) 上两篇我们介绍了RTKLIB中精密单点定位的大致流程,今天我们对照RTKLIB学习手册,来学习相应改正公式和误差源 1.在PPP模式中 RTKL ...
php农历生日计算,阴历-农历-转换类 (PHP版)，阴历php
阴历-农历-转换类 (PHP版),阴历phplunarInfo[$year-$this->MIN_YEAR]; if($year==$this->MIN_YEAR&&$mo ...

初识RxJava（三）转换类操作符

前言：

正文：

1、map 操作符

1)、作用

2)、代码

3）、效果

2、FlatMap 操作符

1）、作用

2）、代码

3)、效果

3、concatMap 操作符

1）、作用

2）、代码

3)、效果

4、buffer 操作符

1)、作用

2)、代码

3)、效果

初识RxJava（三）转换类操作符相关推荐

最新文章

热门文章

初识RxJava（三）转换类 操作符

前言：

正文：

1、map 操作符

1)、作用

2)、代码

3）、效果

2、FlatMap 操作符

1）、作用

2）、代码

3)、效果

3、concatMap 操作符

1）、作用

2）、代码

3)、效果

4、buffer 操作符

1)、作用

2)、代码

3)、效果

初识RxJava（三）转换类 操作符相关推荐

最新文章

热门文章

初识RxJava（三）转换类操作符

初识RxJava（三）转换类操作符相关推荐