RxJava

Subscriber和Observer的差异

Subscriber和Observer不只基本使用方式同样。实质上，在 RxJava 的 subscribe 过程当中。Observer 也老是会先被转换成一个 Subscriber 再使用。因此假设你仅仅想使用基本功能。选择 Observer 和 Subscriber 是全然同样的。它们的差异对于使用者来讲主要有两点：

1. onStart(): 这是 Subscriber 添加的方法。它会在 subscribe 刚開始。而事件还未发送以前被调用。可以用于作一些准备工做。好比数据的清零或重置。

   这是一个可选方法，默认状况下它的实现为空。

   需要注意的是，假设对准备工做的线程有要求（好比弹出一个显示运行进度的对话框。这必须在主线程运行）。 onStart() 就不适用了，因为它老是在 subscribe 所发生的线程被调用，而不能指定线程。要在指定的线程来作准备工做。可以使用 doOnSubscribe() 方法。详细可以在后面的文中看到。

2. unsubscribe(): 这是 Subscriber 所实现的还有一个接口 Subscription 的方法，用于取消订阅。在这种方法被调用后，Subscriber 将再也不接收事件。通常在这种方法调用前。可以使用 isUnsubscribed() 先推断一下状态。 unsubscribe() 这种方法很是重要，因为在 subscribe() 以后， Observable 会持有 Subscriber 的引用。这个引用假设不能及时被释放。将有内存泄露的风险。

   因此最好保持一个原则：要在再也不使用的时候尽快在合适的地方（好比 onPause() onStop() 等方法中）调用 unsubscribe() 来解除引用关系，以免内存泄露的发生。

变换

RxJava 提供了对事件序列进行变换的支持，这是它的核心功能之中的一个，也是大多数人说『RxJava 真是太好用了』的最大缘由。所谓变换。就是将事件序列中的对象或整个序列进行加工处理。转换成不一样的事件或事件序列。

操做符

事实上操做符就是为了提供一些函数式的特性。函数式最大的优势就是处理数据简洁易懂。

map就是至关于对每一个元素进行变换，返回变换后的集合
filter就是对集合进行过滤
each就是遍历集合
take取出集合中的前几个
skip跳过前几个元素
unique至关于依照数学上的集合处理，去重

事实上我认为题主认为最难理解的应该是flatMap和Observable的概念吧。

Observable可以理解成lazy load的集合。

flatMap想当于对lazyLoad的集合中的每一个元素再进行一次lazy load。

（此段引用自hi大头鬼hi）

变换操做

这些操做符可用于对Observable发射的数据进行变换，详解可以看每一个操做符的文档

操做符	含义
Buffer	缓存，可以简单的理解为缓存。它按期从Observable收集数据到一个集合，而后把这些数据集合打包发射，而不是一次发射一个
FlatMap	扁平映射，将Observable发射的数据变换为Observables集合。而后将这些Observable发射的数据平坦化的放进一个单独的Observable。可以认为是一个将嵌套的数据结构展开的过程。
GroupBy	分组，将原来的Observable分拆为Observable集合。将原始Observable发射的数据按Key分组。每一个Observable发射一组不一样的数据
Map	映射，经过对序列的每一项都应用一个函数变换Observable发射的数据。实质是对序列中的每一项运行一个函数，函数的參数就是这个数据项
Scan	扫描。对Observable发射的每一项数据应用一个函数，而后按顺序依次发射这些值
Window	窗体，按期未来自Observable的数据分拆成一些Observable窗体，而后发射这些窗体。而不是每次发射一项。类似于Buffer，但Buffer发射的是数据，Window发射的是Observable，每一个Observable发射原始Observable的数据的一个子集

组合操做

组合操做符用于将多个Observable组合成一个单一的Observable

操做符	含义
And/Then/When	经过模式(And条件)和计划(Then次序)组合两个或多个Observable发射的数据集
CombineLatest	当两个Observables中的不论什么一个发射了一个数据时。经过一个指定的函数组合每一个Observable发射的最新数据（一共两个数据）。而后发射这个函数的结果
Join	无论什么时候，假设一个Observable发射了一个数据项。仅仅要在还有一个Observable发射的数据项定义的时间窗体内，就将两个Observable发射的数据合并发射
Merge	将两个Observable发射的数据组合并成一个
StartWith	在发射原来的Observable的数据序列以前。先发射一个指定的数据序列或数据项
Switch	将一个发射Observable序列的Observable转换为这样一个Observable：它逐个发射那些Observable近期发射的数据
Zip	打包，使用一个指定的函数将多个Observable发射的数据组合在一块儿，而后将这个函数的结果做为单项数据发射

错误处理

这些操做符用于从错误通知中恢复

操做符	含义
Catch	捕获。继续序列操做，将错误替换为正常的数据，从onError通知中恢复
Retry	重试，假设Observable发射了一个错误通知。又一次订阅它。期待它正常终止

辅助操做

一组用于处理Observable的操做符

操做符	含义
Delay	延迟一段时间发射结果数据
Do	注冊一个动做占用一些Observable的生命周期事件，至关于Mock某个操做
Materialize/Dematerialize	将发射的数据和通知都当作数据发射，或者反过来
ObserveOn	指定观察者观察Observable的调度程序（工做线程）
Serialize	强制Observable按次序发射数据并且功能是有效的
Subscribe	收到Observable发射的数据和通知后运行的操做
SubscribeOn	指定Observable应该在哪一个调度程序上运行
TimeInterval	将一个Observable转换为发射两个数据之间所耗费时间的Observable
Timeout	加入超时机制。假设过了指定的一段时间没有发射数据，就发射一个错误通知
Timestamp	给Observable发射的每一个数据项加入一个时间戳
Using	建立一个仅仅在Observable的生命周期内存在的一次性资源

条件和布尔操做

这些操做符可用于单个或多个数据项，也可用于Observable

操做符	含义
All	推断Observable发射的所有的数据项是否都知足某个条件
Amb	给定多个Observable，仅仅让第一个发射数据的Observable发射所有数据
Contains	推断Observable是否会发射一个指定的数据项
DefaultIfEmpty	发射来自原始Observable的数据，假设原始Observable没有发射数据。就发射一个默认数据
SequenceEqual	推断两个Observable是否按相同的数据序列
SkipUntil	丢弃原始Observable发射的数据。直到第二个Observable发射了一个数据。而后发射原始
SkipWhile	丢弃原始Observable发射的数据，直到一个特定的条件为假，而后发射原始Observable剩余的数据
TakeUntil	发射来自原始Observable的数据，直到第二个Observable发射了一个数据或一个通知
TakeWhile	发射原始Observable的数据，直到一个特定的条件为真，而后跳过剩余的数据

算术和聚合操做

这些操做符可用于整个数据序列

操做符	含义
Average	计算Observable发射的数据序列的平均值，而后发射这个结果
Concat	不交错的链接多个Observable的数据
Count	计算Observable发射的数据个数，而后发射这个结果
Max	计算并发射数据序列的最大值
Min	计算并发射数据序列的最小值
Reduce	按顺序对数据序列的每一个应用某个函数，而后返回这个值
Sum	计算并发射数据序列的和

链接操做

一些有精确可控的订阅行为的特殊Observable

操做符	含义
Connect	指示一个可链接的Observable開始发射数据给订阅者
Publish	将一个普通的Observable转换为可链接的
RefCount	使一个可链接的Observable表现得像一个普通的Observable
Replay	确保所有的观察者收到相同的数据序列，即便他们在Observable開始发射数据以后才订阅

转换操做

操做符	含义
To	将Observable转换为其余的对象或数据结构
Blocking	堵塞Observable的操做符

參考：
Intro To RxJava 系列教程 - 云在千峰
给 Android 开发人员的 RxJava 详解
RxJava 入门 - 傅圆的博客 | MrFu Blog
RxJava学习总结 - 推酷
Operators—-RxWeekend - 傅圆的博客 | MrFu Blog