前一篇文章讲述 RxSwift 框架中最重要的类 Observable<T> ，但是其局限性只能作为被订阅者被动接收信号并响应事件。项目中避免不了主动发出信号操作的情况，这时就需要 Subject 类来完成。与之前RAC框架中的 Subject 类功能非常相似，既能攻也能受，是不仅可以成为可观察对象被动接受事件，还可以成为观察者主动发送事件。
Subject 其订阅者也是 Observable，首先可以动态地接受新值，其次当 subject 值更新时，会通过 event 把新值发送给所有的订阅者。
在 RxSwift 框架中，提供了四种类型的 subject，首先要了解的一点就是提供的四种 subject 创建方式最主要的区别：当一个新的订阅者订阅到subject对象时，能否收到 subject 以前发出过的旧 event，如果能，接收的数量又有不同。
-
PublishSubject最普通的 subject ，不需要初始值就可以创建，而且从订阅者开始订阅的时间点起，可以收到 subject 发出的新 event，而不会收到在订阅前已发出的 event -
BehaviorSubject当订阅者订阅 subject 时，会立即收到 BehaviorSubject 上一个发出的 event，之后与 PublishSubject 功能相同 -
ReplaySubject除了包含 PublishSubject 的功能，还可以手动设置订阅者接收到旧的 event 个数。因此，在使用时必须在创建时设置 bufferSize，表示将会返回给订阅者对应个数最近缓存的旧 event
（注：若一个订阅者去订阅已经结束的 ReplaySubject ，除了会收到缓存的 .next 的 event之外，还会收到终结该 ReplaySubject 的 .error 或 .completed 的event）
在实际开发过程中，ReplaySubject 缓存机制使用了数组结构，所以当有大量 ReplaySubject 对象时可能导致内存暴增。另外，如果缓存对象是图片、视频等极耗内存的资源时也可能导致内存问题。所以 ReplaySubject 不可滥用且缓存区大小必须合理进行设置，必要时可手动进行释放管理 -
Variable本身是对 BehaviorSubject 封装，创建时也必须设置一个默认值。继承自 BehaviorSubject ，那么就能向订阅者发出上一个 event 与新的 event。与 BehaviorSubject 不同的是，Variable还会把当前发出的值保存为自己的状态，同时在销毁时自动发送 .completed event，不需要也不能手动给 Variable 发送终结事件 .completed 或 .error 来终结。
换个方式理解，Variable 有一个 value 属性，当改变 value 属性的值时就相当于调用一般 Subjects 的 onNext() 方法，而这个最新的 onNext() 的值就被保存在 value 属性里，直到再次修改 value
（注：Variable 本身没有提供 subscribe() 方法，但是所有 Subjects 都有一个 asObservable() 方法。可以使用这个方法返回这个 Variable 的 Observable 类型，拿到这个 Observable 类型就能订阅它了）
介绍了以上四种 subject ，接下来贴代码并附上运行打印截图，有兴趣的可以copy下来运行一遍，了解其 event 执行顺序
PublishSubject代码示例
let subject = PublishSubject<String>()
subject.onNext("first signal")
subject.subscribe(onNext: { (event) in
print("first event is"+event)
}, onCompleted: {
print("completed first")
}) {
print("first :销毁了")
}.disposed(by: disposeB)
subject.onNext("second signal")
subject.subscribe(onNext: { (event) in
print("second event is "+event)
}, onCompleted: {
print("completed second")
}) {
print("second :销毁了")
}.disposed(by: disposeB)
//让subject结束,后面再进行订阅
subject.onCompleted()
subject.onNext("third signal")
subject.onNext("fourth signal")
subject.subscribe(onNext: { (event) in
print("this is another"+event)
}, onCompleted: {
print("completed another")
}) {
print("another :销毁了")
}.disposed(by: disposeB)
PublishSubject打印结果
BehaviorSubject代码示例
let subject = BehaviorSubject(value: "first signal")
subject.onNext("another first signal") //会替换了 first signal 的信号
subject.subscribe(onNext: { (event) in
print(event)
} , onCompleted: {
print("completed")
}) {
print("第一个销毁了")
}.disposed(by: disposeB)
subject.onNext("second signal")
subject.onNext("third signal") //这里试图替换上面的 second signal 的event
subject.subscribe(onNext: { (event) in
print(event)
} , onCompleted: {
print("completed")
}) {
print("第二个销毁了")
}.disposed(by: disposeB)
subject.onError(NSError(domain: "myError", code: 10010, userInfo: ["myUserInfo":"10010错误"]))
BehaviorSubject打印结果
ReplaySubject代码示例
//设置缓存最近2个event
let subject = ReplaySubject<String>.create(bufferSize: 2)
subject.onNext("first")
subject.onNext("second")
subject.onNext("third")
subject.subscribe(onNext: { (event) in
print(event)
}, onError: { (error) in
print(error)
}, onCompleted: {
print("这是一个 完成")
}) {
print("销毁了")
}.disposed(by: disposeB)
subject.onCompleted()//现在终结subject
subject.subscribe(onNext: { (event) in
print(event)
}, onError: { (error) in
print(error)
}, onCompleted: {
print("完成之后的订阅完成")
}) {
print("完成之后销毁了")
}.disposed(by: disposeB)
ReplaySubject打印结果
Variable代码示例
let subject = Variable("first")
subject.value = "second"
subject.asObservable().subscribe(onNext: { (event) in
print(event)
}, onError: { (error) in
print(error)
}, onCompleted: {
print("Variber订阅完成")
}) {
print("Variber销毁")
}
.disposed(by: disposeB)
subject.value = "third"
Variable打印结果
打印结果中给出了一个警告，在其GitHub的issue链接中，提到了 Variable 要在接下来的版本里删除，请用 BehaviorRelay 代替，其实 Variable 封装，还是比较顺手。貌似现在UI层的很多都是 Variable 来管理，但 RxSwift 也封装了很多关于UI的，issue的回复中说以后会销毁，注意是销毁 Variable 这个类。
网友评论