RxSwfit 学习笔记（四）AsyncSubject、Publ

在RxSwfit 学习笔记（二）Observable & Observer中，我们有聊到“既是可监听序列也是观察者”的情况，并且框架有给我们定义了一些辅助类型，一起来了解一下吧。

这五种的区别

AsyncSubject ：只发 最后一个 元素给观察者，有error只出error
PublishSubject： 只发 订阅后 的元素给观察者，会把error前的元素发出来
ReplaySubject ： 会把 订阅前的n个 元素以及 订阅后 的元素发给观察者，会把error前的元素发出来
BehaviorSubject：有一个 默认值 如果订阅前没发过元素，就会发默认值，有error只出error
ControlProperty：专门用于描述 UI 控件属性，不会出error，一定在主线程上操作

AsyncSubject

RxSwift 中文文档 中提到
AsyncSubject 将在Observable 产生完成事件后，发出最后一个元素（仅仅只有最后一个元素），如果源Observable 没有发出任何元素，只有一个完成事件。那AsyncSubject 也只有一个完成事件。

它会对随后的观察者发出最终元素。如果Observabl 因为产生了一个 error 事件而中止， AsyncSubject 就不会发出任何元素，而是将这个 error 事件发送出来。”

再解读一下

1. 当Observable做了onCompleted()之后，才会将我们发送的最后一个onNext()发送出来。如果只有onCompleted()，那么就只能观察到完成事件。
2. 当Observable做了onError()之后，观察者只能观察到Error事件

AsyncSubject 案例

enum TestError: Error {
    case errorA
    case errorB
}

let asyncSubject = AsyncSubject<String>()

asyncSubject.subscribe{print($0)}.disposed(by: disposeBag)

asyncSubject.onNext("这是第一条消息，不会打印出来")
asyncSubject.onNext("这是第二条消息，不会打印出来")
//asyncSubject.onError(TestError.errorA)
asyncSubject.onNext("这是第三条消息")
//asyncSubject.onCompleted()

AsyncSubject 打印结果

1. 无Error 无Completed 只有onNext

就是什么都没有

2. 无Error 有onNext 有Completed

next(这是第三条消息)
completed

3. 只有Completed

completed

4. 有Error

error(errorA)

PublishSubject

PublishSubject 将对观察者发送订阅后产生的元素，而在订阅前发出的元素将不会发送给观察者。如果你希望观察者接收到所有的元素，你可以通过使用Observable 的create方法来创建 Observable，或者使用 ReplaySubject。

如果源Observable因为产生了一个error事件而中止， PublishSubject就不会发出任何元素，而是将这个error事件发送出来。”
摘录来自: “RxSwift 中文文档。”

继续解读一下

1. PublishSubject只给观察者发订阅后的事件
2. 如果Observable发送了一个
3. 经过实验，在订阅之后，error之前，的事件是可以发出来的

PublishSubject 案例

let publishSubject = PublishSubject<String>()

publishSubject.onNext("订阅前的消息")

publishSubject.subscribe{print($0)}.disposed(by: disposeBag)

publishSubject.onNext("订阅后的消息")
//publishSubject.onError(TestError.errorA)
publishSubject.onNext("再来一条订阅后的")

publishSubject.onCompleted()

PublishSubject 打印结果

1. 无error 无Completed

next(订阅后的消息)
next(再来一条订阅后的)

2. 无error 有Completed

next(订阅后的消息)
next(再来一条订阅后的)
completed

3. 有error

next(订阅后的消息)
error(errorA)

ReplaySubject

ReplaySubject将对观察者发送全部的元素，无论观察者是何时进行订阅的。

这里存在多个版本的ReplaySubject，有的只会将最新的 n 个元素(这个n由我们自己定)发送给观察者，有的只会将限制时间段内最新的元素发送给观察者。

如果把 ReplaySubject 当作观察者来使用，注意不要在多个线程调用 onNext, onError 或onCompleted。这样会导致无序调用，将造成意想不到的结果。

摘录来自: “RxSwift 中文文档。”

解读

1. ReplaySubject会把订阅之前的消息发给观察者，但是有可能只发最新的一部分
2. 慎用 ReplaySubject
3. 经试验，error的情况为订阅前的n个

ReplaySubject 案例

//bufferSize 就是我们上文提到的n
let replaySubject = ReplaySubject<String>.create(bufferSize: 1)

replaySubject.onNext("订阅前的消息1")
replaySubject.onNext("订阅前的消息2")
replaySubject.onNext("订阅前的消息3")

replaySubject.subscribe{print($0)}.disposed(by: disposeBag)

replaySubject.onNext("订阅后的消息")
//replaySubject.onError(TestError.errorA)
replaySubject.onNext("再来一条订阅后的")

replaySubject.onCompleted()

ReplaySubject 打印结果

1. bufferSize = 1

next(订阅前的消息3)
next(订阅后的消息)
next(再来一条订阅后的)
completed

2. bufferSize = 3

next(订阅前的消息1)
next(订阅前的消息2)
next(订阅前的消息3)
next(订阅后的消息)
next(再来一条订阅后的)
completed

3. bufferSize = 3 出现了 error

next(订阅前的消息1)
next(订阅前的消息2)
next(订阅前的消息3)
next(订阅后的消息)
error(errorA)

BehaviorSubject

当观察者对 BehaviorSubject 进行订阅时，它会将源Observable中最新的元素发送出来（如果不存在最新的元素，就发出默认元素）。然后将随后产生的元素发送出来。

如果源 Observable因为产生了一个error事件而中止， BehaviorSubject 就不会发出任何元素，而是将这个error 事件发送出来。

摘录来自: “RxSwift 中文文档。”

解读

1. BehaviorSubject有一个默认元素的概念，订阅后先发默认元素，再发后续onNext()发送出来的元素
2. 出错的时候就只发error事件
3. 如果订阅前就有发出元素，那么就不会发送默认值，但订阅前的元素只会发出一个

BehaviorSubject 案例

let behaviorSubject = BehaviorSubject<String>(value: "默认值")
//behaviorSubject.onNext("订阅前的消息1")
//behaviorSubject.onNext("订阅前的消息2")
//behaviorSubject.onNext("订阅前的消息3")

behaviorSubject.subscribe{print($0)}.disposed(by: disposeBag)

behaviorSubject.onNext("订阅后的消息")
//behaviorSubject.onError(TestError.errorA)
behaviorSubject.onNext("再来一条订阅后的")

behaviorSubject.onCompleted()

BehaviorSubject 打印结果

1. 没有订阅前消息

next(默认值)
next(订阅后的消息)
next(再来一条订阅后的)
completed

2. 有订阅前消息

next(订阅前的消息3)
next(订阅后的消息)
next(再来一条订阅后的)
completed

3. 有error

next(订阅前的消息3)
next(订阅后的消息)
error(errorA)

ControlProperty

ControlProperty 专门用于描述 UI 控件属性的，它具有以下特征：

• 不会产生 error 事件
• 一定在 MainScheduler 订阅（主线程订阅）
• 一定在 MainScheduler 监听（主线程监听）
• 共享附加作用

摘录来自: “RxSwift 中文文档。”

ControlProperty 有别于上面4种辅助类型，下次再看看情况。