一
github地址
标准观察者和Rxjava观察者对比
图片.png
- 标准观察者模式：多个观察者一个被观察者
- Rxjava模式：可以有多个被观察者(Observable)一个观察者(Observer)
装饰模型
图一.png
图二.png
图三.png
- Observable封包：将不同Observable进行层层封包，装饰模式，如图二
- 订阅subscribe开始：拆包(Observable)的同时进行(Observer)封包
- 事件流开始发送事件：经过第一、二步骤之后，开始(Emitter)发送事件，再次拆包(Observer),如图一右侧
SubscribeOn
图4.png
- 作用于拆包和封包阶段，对上游代码产生影响(没有设置observeOn的时候对下游代码也会产生影响)，多次设置(连续设置多次)最先设置的Scheduler会覆盖后边的Scheduler，如图4
ObserveOn
图5.png
- 作用于事件流拆包(Observer)发送阶段,对下游代码产生作用，主要是对onNext，onError，onComplete方法封装并采用指定的线程执行，多次连续设置最后一次设置会覆盖前边设置
