框架里面定义了一些辅助类型，它们既是可监听序列也是观察者。如果你能合适的应用这些辅助类型，它们就可以帮助你更准确的描述事物的特征
一、AsyncSubject
AsyncSubject 将在源 Observable 产生完成事件后，发出最后一个元素（仅仅只有最后一个元素），如果源 Observable 没有发出任何元素，只有一个完成事件。那 AsyncSubject 也只有一个完成事件。
它会对随后的观察者发出最终元素。如果源 Observable 因为产生了一个 error 事件而中止， AsyncSubject 就不会发出任何元素，而是将这个 error 事件发送出来。
整个例子
AsyncSubject
直接到代码里看
接收事件的处理
当self._stoppedEvent存在的时候会接收事件，去onNext()方法中去找找self._stoppedEvent是什么，self._observers.insert(observer.on)表示会把observr.on保存到了self._observers里
onNext()方法接下来走on()方法
看一下(observers，event)是什么
_synchronized_on()方法
当事件类型是元素时，只会保存一个元素，observers是一个空的Observer()
当事件类型是error时，self._stoppedEvent是错误事件
当事件类型是completed时，如果self._lastElement中存在元素，则self._stoppedEvent是当前元素，而不存在的时候self._stoppedEvent是completed，去看dispatch()方法
dispatch
bag._onlyFastPath初始值为true，当调用self._observers.insert(observer.on)，bag._onlyFastPath
element是self. _observers保存的observer.on，也就是说如果bag._onlyFastPath为false的时候，会遍历bag_dictionary 调用element(event)即 observer.on(event)
再回过头去看_synchronized_subscribe方法
image.png
这时候我们就差不多可以看出来AsyncSubject的特征了。
AsyncSubject 将在源 Observable 产生完成事件后，发出最后一个元素（仅仅只有最后一个元素），如果源 Observable 没有发出任何元素，只有一个完成事件。那 AsyncSubject 也只有一个完成事件。
它会对随后的观察者发出最终元素。如果源 Observable 因为产生了一个 error 事件而中止， AsyncSubject 就不会发出任何元素，而是将这个 error 事件发送出来。
二、PublishSubject
PublishSubject 将对观察者发送订阅后产生的元素，而在订阅前发出的元素将不会发送给观察者。如果你希望观察者接收到所有的元素，你可以通过使用
Observable的create方法来创建Observable，或者使用 ReplaySubject。
如果源 Observable 因为产生了一个 error 事件而中止， PublishSubject 就不会发出任何元素，而是将这个 error 事件发送出来。
我们直接看PublishSubject的on()方法，如果在订阅前发送元素的话，self._synchronized_on(event)返回的是一个self._observers，此时呢self._observers._onlyFastPath为true，所以订阅前的元素并不会发送给观察者，而completed和error事件会被self._stoppedEvent，也就是说completed和error如果在订阅前被发送的时候，会在_synchronized_subscribe中被发送，如果在订阅前会在dispatch中被发送.
image.png
三、ReplaySubject
ReplaySubject 将对观察者发送全部的元素，无论观察者是何时进行订阅的。
这里存在多个版本的 ReplaySubject，有的只会将最新的 n 个元素发送给观察者，有的只会将限制时间段内最新的元素发送给观察者。
如果把 ReplaySubject 当作观察者来使用，注意不要在多个线程调用 onNext, onError 或 onCompleted。这样会导致无序调用，将造成意想不到的结果。
ReplaySubject的创建方法没什么好说的，ReplayOne和ReplayMany的基类都是ReplayBufferBase
ReplaySubject的创建方法
ReplayOne和ReplayMany没有on()和subscribe()，网上去它们的父类找，ReplayBufferBase实现了on()和subscribe()
on()方法
subscribe()方法
ReplaySubject会保存订阅前发送的元素，当然数量是和create传进来的参数一致
ReplayOne的addValueToBuffer()方法保存了单个元素
ReplayMany的addValueToBuffer()方法吧元素保存到了队列里
ReplayMany的trim()方法保证了队列的数量和设定的数量一致
在_synchronized_subscribe()方法中有这么一句
image.png
点进去看不难发现这句话是接收到了响应
ReplayOne的replayBuffer()方法
ReplayMany的replayBuffer()
订阅前发送的error事件和completed事件
如果订阅前没有触发error事件和completed事件，self._observers会保存observer.on()
而订阅后发出的元素或事件会在on()方法的dispatch()方法中把保存的observer.on()回调
四、BehaviorSubject
当观察者对 BehaviorSubject 进行订阅时，它会将源 Observable 中最新的元素发送出来（如果不存在最新的元素，就发出默认元素）。然后将随后产生的元素发送出来。如果源 Observable 因为产生了一个 error 事件而中止， BehaviorSubject 就不会发出任何元素，而是将这个 error 事件发送出来。
BehaviorSubject初始化保存一个元素
BehaviorSubject初始化保存一个元素
不难看出每次发送元素都会保存最新的元素，而self.stoppedEvent保存了error事件和comleted事件
BehaviorSubject的on()方法
再去看subscribe()方法
BehaviorSubject的subscribe()
不难看出如果在订阅前就发送了error事件或者completed事件，则一个元素都不会响应，如果订阅前没有error事件或者comleted事件，则self._observers保存observer.on，同时会发送一个最新的元素。
之后订阅的元素或者事件会在dispatch()中回调。
五、ControlProperty
ControlProperty 专门用于描述 UI 控件属性的，它具有以下特征：
- 不会产生
error事件- 一定在
MainScheduler订阅（主线程订阅）- 一定在
MainScheduler监听（主线程监听）- 共享附加作用
ControlProperty和ControlEvent都是专门用于UI，不同的是ControlEvent是一个序列，ControlProperty即是一个队列同时也是一个观察者
ControlProperty保存了一个序列和一个观察者
ControlEvent只保存了一个序列
在RxCocoa中，创建的ControlProperty中观察者通常是一个Binder
RxCocoa中创建的ControlProperty
网友评论