RxSwift中的subject，subject是observable和Observer之间的桥梁，一个subject既是一个obserable也是一个observe，它既可以发出事件也可以监听事件
1.publicSubject：订阅publicSubject时，只能接收到订阅他之后发生的事件，subject.onNext()发出onNext事件，对应的还有onError()和onComplete()事件
2.replaySubject：订阅replaySubject时，可以接收到订阅他之后的事件，但也可以接受订阅他之前发出的事件，接受几个事件取决于bufferSize的大小
3.behaviorSubject：订阅behaviorSubject,可以接收到订阅之前的最后一个事件，这个在tableView中用的比较多，一般就是初始化数据显示空值。
1，Subjects 基本介绍
（1）Subjects 既是订阅者，也是 Observable：
- 说它是订阅者，是因为它能够动态地接收新的值。
- 说它又是一个
Observable，是因为当Subjects有了新的值之后，就会通过Event将新值发出给他的所有订阅者。
（2）一共有四种 Subjects，分别为：PublishSubject、BehaviorSubject、ReplaySubject、Variable。他们之间既有各自的特点，也有相同之处：
- 首先他们都是
Observable，他们的订阅者都能收到他们发出的新的Event。 - 直到
Subject发出.complete或者.error的Event后，该Subject便终结了，同时它也就不会再发出.next事件。 - 对于那些在
Subject终结后再订阅他的订阅者，也能收到subject发出的一条.complete或.error的event，告诉这个新的订阅者它已经终结了。 - 他们之间最大的区别只是在于：当一个新的订阅者刚订阅它的时候，能不能收到
Subject以前发出过的旧Event，如果能的话又能收到多少个。
（3）Subject 常用的几个方法：
-
onNext(:)：是
on(.next(:))的简便写法。该方法相当于subject接收到一个.next事件。 -
onError(:)：是
on(.error(:))的简便写法。该方法相当于subject接收到一个.error事件。 -
onCompleted()：是
on(.completed)的简便写法。该方法相当于subject接收到一个.completed事件。
2，PublishSubject
（1）基本介绍
-
PublishSubject是最普通的Subject，它不需要初始值就能创建。 -
PublishSubject的订阅者从他们开始订阅的时间点起，可以收到订阅后Subject发出的新Event，而不会收到他们在订阅前已发出的Event。
（2）时序图
- 最上面一条是
PublishSubject。 - 下面两条分别表示两个新的订阅，它们订阅的时间点不同，可以发现
PublishSubject的订阅者只能收到他们订阅后的Event。
image
（3）使用样例
let disposeBag = DisposeBag()
//创建一个PublishSubject
let subject = PublishSubject<String>()
//由于当前没有任何订阅者，所以这条信息不会输出到控制台
subject.onNext("111")
//第1次订阅subject
subject.subscribe(onNext: { string in
print("第1次订阅：", string)
}, onCompleted:{
print("第1次订阅：onCompleted")
}).disposed(by: disposeBag)
//当前有1个订阅，则该信息会输出到控制台
subject.onNext("222")
//第2次订阅subject
subject.subscribe(onNext: { string in
print("第2次订阅：", string)
}, onCompleted:{
print("第2次订阅：onCompleted")
}).disposed(by: disposeBag)
//当前有2个订阅，则该信息会输出到控制台
subject.onNext("333")
//让subject结束
subject.onCompleted()
//subject完成后会发出.next事件了。
subject.onNext("444")
//subject完成后它的所有订阅（包括结束后的订阅），都能收到subject的.completed事件，
subject.subscribe(onNext: { string in
print("第3次订阅：", string)
}, onCompleted:{
print("第3次订阅：onCompleted")
}).disposed(by: disposeBag)
运行结果如下：
image
3，BehaviorSubject
（1）基本介绍
-
BehaviorSubject需要通过一个默认初始值来创建。 - 当一个订阅者来订阅它的时候，这个订阅者会立即收到
BehaviorSubjects上一个发出的event。之后就跟正常的情况一样，它也会接收到BehaviorSubject之后发出的新的event。
（2）时序图
- 最上面一条是
BehaviorSubject。 - 下面两条分别表示两个新的订阅，它们订阅的时间点不同，可以发现
BehaviorSubject的订阅者一开始就能收到BehaviorSubjects之前发出的一个Event。
image
]
（3）使用样例
let disposeBag = DisposeBag()
//创建一个BehaviorSubject
let subject = BehaviorSubject(value: "111")
//第1次订阅subject
subject.subscribe { event in
print("第1次订阅：", event)
}.disposed(by: disposeBag)
//发送next事件
subject.onNext("222")
//发送error事件
subject.onError(NSError(domain: "local", code: 0, userInfo: nil))
//第2次订阅subject
subject.subscribe { event in
print("第2次订阅：", event)
}.disposed(by: disposeBag)
运行结果如下：
image
4，ReplaySubject
（1）基本介绍
-
ReplaySubject在创建时候需要设置一个bufferSize，表示它对于它发送过的event的缓存个数。 - 比如一个
ReplaySubject的bufferSize设置为 2，它发出了 3 个.next的event，那么它会将后两个（最近的两个）event给缓存起来。此时如果有一个subscriber订阅了这个ReplaySubject，那么这个subscriber就会立即收到前面缓存的两个.next的event。 - 如果一个
subscriber订阅已经结束的ReplaySubject，除了会收到缓存的.next的event外，还会收到那个终结的.error或者.complete的event。
（2）时序图
- 最上面一条是
ReplaySubject（bufferSize设为为 2）。 - 下面两条分别表示两个新的订阅，它们订阅的时间点不同。可以发现
ReplaySubject的订阅者一开始就能收到ReplaySubject之前发出的两个Event（如果有的话）。
image
（3）使用样例
let disposeBag = DisposeBag()
//创建一个bufferSize为2的ReplaySubject
let subject = ReplaySubject<String>.create(bufferSize: 2)
//连续发送3个next事件
subject.onNext("111")
subject.onNext("222")
subject.onNext("333")
//第1次订阅subject
subject.subscribe { event in
print("第1次订阅：", event)
}.disposed(by: disposeBag)
//再发送1个next事件
subject.onNext("444")
//第2次订阅subject
subject.subscribe { event in
print("第2次订阅：", event)
}.disposed(by: disposeBag)
//让subject结束
subject.onCompleted()
//第3次订阅subject
subject.subscribe { event in
print("第3次订阅：", event)
}.disposed(by: disposeBag)
运行结果如下：
image
5，Variable
（1）基本介绍
-
Variable其实就是对BehaviorSubject的封装，所以它也必须要通过一个默认的初始值进行创建。 -
Variable具有BehaviorSubject的功能，能够向它的订阅者发出上一个event以及之后新创建的event。 - 不同的是，
Variable还会把当前发出的值保存为自己的状态。同时它会在销毁时自动发送.complete的event，不需要也不能手动给Variables发送completed或者error事件来结束它。 - 简单地说就是
Variable有一个value属性，我们改变这个value属性的值就相当于调用一般Subjects的onNext()方法，而这个最新的onNext()的值就被保存在value属性里了，直到我们再次修改它。
注意：
Variables本身没有subscribe()方法，但是所有Subjects都有一个asObservable()方法。我们可以使用这个方法返回这个Variable的Observable类型，拿到这个Observable类型我们就能订阅它了。
（2）使用样例
import UIKit
import RxSwift
import RxCocoa
class ViewController: UIViewController {
override func viewDidLoad() {
super.viewDidLoad()
let disposeBag = DisposeBag()
//创建一个初始值为111的Variable
let variable = Variable("111")
//修改value值
variable.value = "222"
//第1次订阅
variable.asObservable().subscribe {
print("第1次订阅：", $0)
}.disposed(by: disposeBag)
//修改value值
variable.value = "333"
//第2次订阅
variable.asObservable().subscribe {
print("第2次订阅：", $0)
}.disposed(by: disposeBag)
//修改value值
variable.value = "444"
}
}
运行结果如下：
注意：由于
Variable对象在viewDidLoad()方法内初始化，所以它的生命周期就被限制在该方法内。当这个方法执行完毕后，这个Variable对象就会被销毁，同时它也就自动地向它的所有订阅者发出.completed事件
image
作者：八级大狂风AM
链接：https://www.jianshu.com/p/def6965b0475
网友评论