Subject 是 Rx 中的基礎(chǔ)性元素之一(Scheduler, Observable, Operator).
雖然 Observable 可以很好地滿足 發(fā)射-觀察 這樣的模式需要, 但在實(shí)際編程中, 很多時(shí)候都需要手動(dòng)在 Observable 上添加新的值并?讓值發(fā)射出去.
實(shí)際上需要的就是一個(gè)既可以作為 Observable 又可以作為 Observer 的元素, 這樣的元素就是 Subject.
概述
首先來看看 PublishSubject 類型, 它是 Subject 的一種.
從它的名字就可以看得出來, 它是一種發(fā)布為主的 Subject. 即它?能夠像報(bào)紙出版商那樣, 接收消息, 然后發(fā)布(publish)消息.
來看看它的使用:
example(of: "PublishSubject") {
let subject = PublishSubject<String>()
subject.onNext("Is anyone listening?")
let subscriptionOne = subject
.subscribe(onNext: { string in
print(string)
})
}
上面的代碼中, 首先新建了一個(gè) PublishSubject, 然后讓他發(fā)布了一條消息, 然后再在下面觀察?它即可. 但是代碼運(yùn)行后, 卻什么也沒有打印. 這就涉及到 Subject 的一些特性需要進(jìn)行學(xué)習(xí)了.
不打印的原因是: PublishSubject 只會(huì)將消息發(fā)布給當(dāng)前的所有觀察者, 如果發(fā)布消息的時(shí)候?這個(gè)觀察者還沒有開始觀察, 當(dāng)然就什么也不會(huì)打印了.
可以在觀察者添加觀察后, 再手動(dòng)發(fā)布一條消息:
subject.on(.next("1"))
這里代碼中的 on(.next(_:)) 操作符表示在該 subject 上面添加一個(gè)新的 next 事件.
?
實(shí)際上下面的代碼功能也是一樣, 只是更好看:
subject.onNext("1")
這時(shí)就會(huì)出現(xiàn)打印信息:
--- Example of: PublishSubject ---
1
什么是 Subject
Subject 實(shí)際上就是既可以作為 Observable, 也可以作為 Observer 的一種對(duì)象.
首先它作為 Observer, 可以接收到 next 事件, 但它接收到事件后并不進(jìn)行處理, 而是轉(zhuǎn)變?yōu)?Observable 的角色, 將該事件發(fā)布出來, 從而觀察它的觀察者可以收到這個(gè)消息.
在 RxSwift 中?共有 4 種 Subject 類型:
-
PublishSubject:
被創(chuàng)建出來的時(shí)候是空的, 只會(huì)發(fā)布最新的消息給?訂閱者(觀察者).
-
BehaviorSubject:
創(chuàng)建的時(shí)候會(huì)賦一個(gè)初始化值給它, 并且如果沒有新值的時(shí)候, 就會(huì)發(fā)布這個(gè)初始值給觀察者, 否則會(huì)發(fā)布最新的值給觀察者.
-
ReplaySubject:
創(chuàng)建的時(shí)候會(huì)指定一個(gè)緩沖區(qū), 并且?維護(hù)一個(gè)包含消息的緩沖區(qū), 當(dāng)有觀察者開始觀察?時(shí), 就會(huì)發(fā)布這個(gè)緩沖區(qū)中的所有值給觀察者.
-
Variable:
它里面包裝了一個(gè) BehaviorSubject, 并將當(dāng)前的值作為狀態(tài)來?維護(hù), 同樣會(huì)發(fā)布初始化值或是最新的值給觀察者.(即開始觀察的時(shí)候會(huì)發(fā)布一次值給觀察者, 開始觀察時(shí)候的這個(gè)值可以是初始化的值, 也可以是被新值替換后的值, 有新值的時(shí)候就發(fā)布新值給觀察者.)
PublishSubject 的使用
?如果只想讓所有的觀察者在有新的消息的時(shí)候被通知到, PublishSubject 就是最好的選擇.
只有當(dāng)觀察者解除觀察(dispose), 或者是產(chǎn)生了 complete 事件或 error 事件, 或是 subject 被銷毀, 才會(huì)停止這個(gè)過程.
還有一個(gè)特性就是: 當(dāng) PublishSubject 發(fā)射了結(jié)束事件, 比如 complete 或 error 后, 它就不會(huì)再發(fā)射任何? next 事件或新的結(jié)束事件了. 但它會(huì)給所有的新觀察者發(fā)布之前的那個(gè)結(jié)束事件.
實(shí)際上, 所有的 subject 都具有該特性, 即它作為 Observable 發(fā)射過 complete 或 error 后, 就不會(huì)再發(fā)射 next 事件了, 且以后所有新的觀察者開始觀察后都只會(huì)接收到一個(gè) complete 或 error 結(jié)束事件.
所以實(shí)踐中最好的做法是每次都對(duì)結(jié)束事件有一個(gè)處理, 以防止在觀察前就已經(jīng)結(jié)束了.
有時(shí)候還希望最新的觀察者能夠獲知之前發(fā)射過的最后一個(gè)數(shù)據(jù)的值, 那么就可以使用下面的 subject.
BehaviorSubject
BehaviorSubject 和 publish subject 類似. 不同點(diǎn)在于它們會(huì)重新發(fā)射上一次的最后一個(gè) next 事件給新的觀察者.
比如下面的代碼:
let disposebag = DisposeBag()
let subject = BehaviorSubject<String>(value: "hello")
subject.subscribe(onNext: {
print($0)
}, onError: {
print($0)
}, onCompleted: {
print("completed")
}, onDisposed: {
print("disposed.")
}).addDisposableTo(disposebag)
subject.onNext("world")
輸出是:
hello
world
在創(chuàng)建 BehaviorSubject 的時(shí)候, 首先給它賦初值, 第一個(gè)觀察者到達(dá)的時(shí)候會(huì)觀察到初始值, 當(dāng)然之后就是觀察到再次發(fā)射的那個(gè)值. 而又有新的觀察者?開始觀察的時(shí)候, 首先是觀察到 world, 也就是最后一個(gè)? next 事件.
當(dāng)然如果是 complete 或者是 error 的話, 也是和一般的 subject 一樣, 向新觀察者只發(fā)送一次.
?但是如果想要展示更多的歷史數(shù)據(jù), 比如在搜索界面, 可能想要展示最近的 5 條查詢條目, 則需要使用下面的 ReplaySubject.
ReplaySubject
Replay subject 帶有緩沖區(qū), 能夠自動(dòng)緩存最多緩沖區(qū)大小個(gè)發(fā)送的歷史事件(數(shù)據(jù)). 當(dāng)新觀察者到達(dá)時(shí), 就把所有的歷史數(shù)據(jù)都發(fā)送給新的觀察者.
由于緩沖區(qū)是在內(nèi)存中建立的, 所以使用 replay subject 的時(shí)候需要額外小心, 比如緩存了大量的大型數(shù)據(jù), 就可能造成內(nèi)存不足. 另外還要注意盡量避免讓 replay subject 緩存數(shù)組類型的元素, 數(shù)組是值類型的, 所以...
下面的代碼?演示了它的使用:
let disposebag = DisposeBag()
let subject = ReplaySubject<String>.create(bufferSize: 2)
subject.onNext("1")
subject.onNext("2")
subject.onNext("3")
subject.subscribe(onNext: {
print($0)
}).addDisposableTo(disposebag)
subject.onNext("4")
subject.subscribe(onNext: {
print($0)
}).addDisposableTo(disposebag)
輸出為:
2
3
3
4
一般情況下, 都是使用 create 方法來創(chuàng)建 ?ReplaySubject.
而當(dāng)遇到 error 或者 complete 之后, 新的觀察者同樣會(huì)先接收到緩沖區(qū)的東西, 然后才是 error 或 complete, 只是此后的 next 都不會(huì)再發(fā)射了.
每次有新的觀察者的時(shí)候, 都是先把緩沖區(qū)中的所有歷史事件都發(fā)送給新的觀察者, 然后再繼續(xù)發(fā)送其他的新的事件.
通過使用 publish, behavior 或者 replay subject, 基本上可以滿足平時(shí)的大部分需求了. 但是另外有許多情況下, 你只是想要去詢問一個(gè) observable : hi, 你當(dāng)前的值是什么? 這個(gè)時(shí)候就需要用到 Variable.
既可以發(fā)射, 還可以直接詢問它的值. 這個(gè)東西好用, 所以下面就來看看 Variable.
Variable
?前面也提到過, Variable 中封裝了一個(gè) BehaviorSubject, 然后將當(dāng)前的值保持為它的狀態(tài). 可以通過 Variable 的 value 屬性來訪問它當(dāng)前的值. 并且和其他 Subject 不同的是, 要讓? Variable 接收一個(gè) next 事件, 直接給它的 value 屬性賦值即可. 而沒有 onNext 方法.
由于它里面封裝了 BehaviorSubject, 故需要通過一個(gè)初始化值來初始化它. 因此, 當(dāng)有新的觀察者到達(dá)時(shí), 會(huì)接收到要么初始化的值, 要么是最新的那個(gè)值.
要觀察的話, 需要通過 asObservable() 來獲取它里面的 Observable.
另外 Variable 還有一個(gè)與眾不同的特點(diǎn): 它可以保證不會(huì)發(fā)送 error. 因?yàn)闊o法在它上面放置 error 事件. 且當(dāng)它被釋放的時(shí)候, 會(huì)自動(dòng)發(fā)送 complete 事件. 所以對(duì)于 Variable 而言, 一般情況下不會(huì)也不需要手動(dòng)去添加 error 或 complete 事件.(因?yàn)闊o論如何嘗試添加 error 或 complete 最后的結(jié)果都是編譯錯(cuò)誤.)
