RxJava基本操作符（变换操作）

基础创建完了，我们学习变换类操作符

Buffer

定期收集Observable的数据放进一个数据包裹，然后发射这些数据包裹，而不是一次发射一个值。
我们看到函授构造的很多，根据需求我们挑选符合自己要求的方法

GroupBy

将一个Observable分拆为一些Observables集合，它们中的每一个发射原始Observable的一个子序列
这个api很有意思，你可以理解为按照指定条件分为一些组，我们在发送1-10的的时候，判断是否大于5，如果大于5就是大于5的一组，这里引入了一个GroupedObservable，有点类似于Map(key,list)这种，可以将它的values继续发送进行处理。

Map

对Observable发射的每一项数据应用一个函数，执行变换操作
我们将传入的数字乘以10转成String

Scan

连续地对数据序列的每一项应用一个函数，然后连续发射结果
我们通过log分析出来，在第一次调用onNext后，integer2就等于上次计算的结果传递了回来，我们计算1加到10，就得出了55的结果，每次都是将上次计算结果返回给integer2，然后integer作为下一个参与的参数继续计算。

Window

定期将来自原始Observable的数据分解为一个Observable窗口，发射这些窗口，而不是每次发射一项数据
window和buffer很像，不过发射出来是一个Observable

cast

在发射之前强制将Observable发射的所有数据转换为指定类型

image.png

swtchMap

将Observable发射的数据集合变换为Observables集合，然后只发射这些Observables最近发射的数据
这个方法要考虑线程问题，如果在一个线程里肯定是先跑先到，但是在不同的线程里，当上一个任务尚未完成时，就开始下一个任务的话，上一个任务就会被取消掉。

同一线程

不同线程
只保留了最新人物

flatMap, concatMap,flatMapIterable

将Observable发射的数据集合变换为Observables集合，然后将这些Observable发射的数据平坦化的放进一个单独的Observable

flatMap

flatMap就是将数据平铺开来，但是结果不保证按照发送的顺序

flatMap

concatMap

它类似于最简单版本的flatMap，但是它按次序连接而不是合并那些生成的Observables，然后产生自己的数据序列，concatMap操作符的功能和flatMap是非常相似的，只是有一点，concatMap 最终输出的数据序列和原数据序列是一致，它是按顺序链接Observables，而不是合并(flatMap用的是合并

flatMapIterable

这个变体成对的打包数据，然后生成Iterable而不是原始数据和生成的Observables，但是处理方式是相同的
操作与flatMap，在流程上，大体都相同。唯一不同的是，flatMap是转一个Observable 转换成多个Observables。每一个Observable，最后又得返回一个Observable。而flatMapIterable在将一个Observable转换成多个Observables后，每一个Observable，只能返回一个Iterable。而不是另一个Observable。 Iterable，可以理解成返回一个list。