一

github地址

Github：https://github.com/ReactiveX/RxJava

标准观察者和Rxjava观察者对比

图片.png

• 标准观察者模式：多个观察者一个被观察者
• Rxjava模式：可以有多个被观察者(Observable)一个观察者(Observer)

装饰模型

图一.png

图二.png

图三.png

1. Observable封包：将不同Observable进行层层封包，装饰模式，如图二
2. 订阅subscribe开始：拆包(Observable)的同时进行(Observer)封包
3. 事件流开始发送事件：经过第一、二步骤之后，开始(Emitter)发送事件，再次拆包(Observer),如图一右侧

SubscribeOn

图4.png

• 作用于拆包和封包阶段，对上游代码产生影响(没有设置observeOn的时候对下游代码也会产生影响)，多次设置(连续设置多次)最先设置的Scheduler会覆盖后边的Scheduler，如图4

ObserveOn

图5.png

• 作用于事件流拆包(Observer)发送阶段,对下游代码产生作用，主要是对onNext，onError，onComplete方法封装并采用指定的线程执行，多次连续设置最后一次设置会覆盖前边设置