ReactiveX是Reactive Extension的缩写。
解决的问题？
更简洁地实现异步和事件驱动应用。
解决的方式？
基于Observable，使我们可以像操作Iterator一样简单地操作异步数据流。Observable可以看成是异步、push版的Iterator。
Observable的优点？
可组合
像Java Futures这样的技术，在单层异步环境下是简单直接的，但是在需要嵌套使用时复杂度就会迅速提高。
而Observables是专门设计用来组合异步数据流的。
弹性强(灵活)
不仅像Futures一样支持单标量值，而且支持数据序列甚至是无限的数据流。
具体实现没有限制
没有对任何并发和异步库的依赖，可以用线程池、事件循环、非阻塞I/O、actors等任何技术来实现，用任何适应的风格。
Observable应该永远被认为是异步的，无论底层实现是阻塞还是非阻塞的。
可以随时修改实现而不影响使用。
Callbacks的问题
与Futures一样，对于单层异步任务，简单易用。而对于需要多层嵌套的场景就难于处理了。
核心概念
Observable和Observer
Observer订阅Observable。
对外输出数据的对象，可以被监听。
对外产生三种事件：
- onNext: 输出数据，可多次调用。
- onCompleted: 输出数据完毕。
- onError：出错了。不会再调用onNext和onCompleted。
Hot和Cold
Hot: 一旦创建就开始输出数据，不管有没有Observer。
Cold：直到第一个Observer订阅才会开始输出数据。
Operators
用来对Observable发出的数据序列做转换、合并、组合、过滤等操作。
在Rx中，通过声明式地使用operators对异步序列做处理，即保留了callbacks的效率，又避免了嵌套callbacks的混乱。
Single
一种只输出一个值或错误的Observable。出现在RxJava等实现中。
- onSuccess：输出值
- onError：出错了
Subject
即是Observer，又是Observable。
变形有四种：
AsyncSubject
当源Observable结束时，输出其最后一个值。
BehaviorSubject
在新的Observer订阅时，先输出源Observable的最后一个值（或者其种子/默认值），然后传递输出后续值。
PublishSubject
传递自Observer订阅开始源Observable的值。
ReplaySubject
输出订阅之前，源Observable输出过的所有数据。
Scheduler
用来控制Observable的执行线程以及回调Observer的线程。
与FRP(functional reactive programming)的区别？
FRP针对的是随时间连续变化的数据流。而ReactiveX针对的是随时间被发出的分散数据。
