前言

在上一篇文章我們介紹了 Observable 的基本概念和使用情形。但是大多數(shù)情形下，我們需要在應(yīng)用運行時添加數(shù)據(jù)到 Observable 中并將其發(fā)送給訂閱者。在這種需求場景下，我們就不得不使用 RxSwift 中另一種類型對象了 - Subject 。

在應(yīng)用中 Subject 實際上同時扮演了兩個不同的角色：既是可觀察對象同時也是觀察者。這意味著 Subject 實例對象既可以接收事件也可以發(fā)送事件。例如，Subject 實例對象可以接收 next 事件信息，然后再將其發(fā)送給它自己的訂閱者。示例代碼：

let subject = PublishSubject<String>()let subscriptionOne = subject       .subscribe(onNext: { string in        print(string)       })subject.on(.next("1"))/* 打印結(jié)果：1*/

上面代碼中使用的是 PublishSubject 類型的示例，而 RxSwift 中總共也四種類型的 Subject：

• PublishSubject：初始化時并不包含數(shù)據(jù)，并且只會給訂閱者發(fā)送后續(xù)數(shù)據(jù)。
• BehaviorSubject：創(chuàng)建時需要包含初始數(shù)據(jù)，并且會給訂閱者發(fā)送后續(xù)數(shù)據(jù)和最近的一次數(shù)據(jù)。
• ReplaySubject：創(chuàng)建時需要指定對象緩存區(qū)容量，該容量表示會給訂閱者重新發(fā)送訂閱前數(shù)據(jù)的大小。
• Variable：BehaviorSubject 對象的封裝類型。它會將當(dāng)前數(shù)據(jù)保存為狀態(tài)并且只會給訂閱者重新發(fā)送最近或者初始值。

下面將詳細(xì)介紹這四種類型對象的概念以及它們的區(qū)別和使用情況。

PublishSubject

如果你僅僅是想讓訂閱者獲取被觀察者在生命周期內(nèi)若產(chǎn)生的數(shù)據(jù)的話，那么你完全可以選用 PublishSubject 。而且 PublishSubject 對象的行為符合正常的預(yù)期，它只會給訂閱者發(fā)送其訂閱開始之后的數(shù)據(jù)。

例如，下圖的最上面的時間線表示被觀察者所發(fā)送的事件，而下面兩個則分別代表不同的觀察者?？梢钥吹较旅鎯蓚€觀察者都只會接收到訂閱后所發(fā)送的事件而無法獲知之前的情形。

對應(yīng)的代碼為：

let subject = PublishSubject<String>()let subscriptionOne = subject       .subscribe(onNext: { event in        print("1) /( event.element ?? event)" )       })subject.on(.next("1")) let subscriptionTwo = subject       .subscribe(onNext: { event in        print("2) /(event.element ?? event)")       }) subject.on(.next("2")) subject.on(.next("3")) /* 打印結(jié)果1) 11) 22) 21) 32) 3*/

如果此時我們?nèi)∠?subscriptionOne 的訂閱并發(fā)送新數(shù)據(jù)的話，那么結(jié)果為：

subscriptionOne.dispose()subject.on(.next("4"))  /* 打印結(jié)果 2) 4 */

另外，當(dāng) PublishSubject 對象生命周期結(jié)束時，無論后續(xù)是否繼續(xù)有數(shù)據(jù)產(chǎn)生該對象只會簡單的發(fā)送之前結(jié)束生命周期的事件。

// 結(jié)束生命周期subject.onCompleted()// 發(fā)送新數(shù)據(jù)subject.onNext("5")// 結(jié)束觀察subscriptionTwo.dispose()let disposeBag = DisposeBag()// 重新進(jìn)行訂閱操作 subject .subscribe {   print("3)", $0.element ?? $0)  }  .addDisposableTo(disposeBag)// 發(fā)送新數(shù)據(jù)subject.onNext("?")/* 打印結(jié)果2) completed3) completed */

對于時序敏感的操作來說，PublishSubject 顯然是非常合適的選擇。但是并不是所有的情形都時序敏感，有時候我們可能會希望在訂閱時能夠獲知最近一次的數(shù)據(jù)。此時，我們就需要使用 BehaviorSubject 對象了。

BehaviorSubject

BehaviorSubject 的行為與 PublishSubject 幾乎一致，不過前者會給訂閱者多發(fā)送一個最近的數(shù)據(jù)。圖解如下：

圖示中最上面對應(yīng)的是所發(fā)射的數(shù)據(jù)，其中第二行表示第一個觀察者，第三行則表示另一個?？梢园l(fā)現(xiàn)第一個觀察者是在 1 之后 2 之前進(jìn)行觀察的，但是它依然能夠獲取到數(shù)據(jù) 1 。我們可以通過代碼進(jìn)行驗證：

let subject = BehaviorSubject(value: "1")let bag = DisposeBag()subject .subscribe { event in   print("1) event: /(event.element!) ") } .addDisposableTo(bag)subject .subscribe { event in  print("2) event: /(event.element!) ") } .addDisposableTo(bag)subject.onNext("2")subject .subscribe { event in  print("3) event: /(event.element!) ") } .addDisposableTo(bag)subject.onNext("3")

因為始終都能獲取到最近的數(shù)據(jù)，所以對于那些可能需要默認(rèn)值的場景，BehaviorSubject 顯然是一個好的選擇。

ReplaySubject

ReplaySubject 與 BehaviorSubject 的行為非常接近，只不過前者允許訂閱者獲取多于 1 個的最近數(shù)據(jù)。所以從某種意義上來說，后者是前者的一個特例。

下圖就是一個 buffer 大小為 2 的 ReplaySubject 對象。它總過發(fā)射了三次數(shù)據(jù)，其中第一個觀察者獲取了所以的數(shù)據(jù)。而第二個觀察者雖然是在第二個數(shù)據(jù)發(fā)射后才開始，但它依舊能獲取緩存區(qū)中保存的數(shù)據(jù)。

代碼表示如下：

let subject = ReplaySubject<String>.create(bufferSize: 2)let bag = DisposeBag()subject .subscribe { event in  print("1) event: /(event.element!) ") } .addDisposableTo(bag)subject.onNext("1")subject.onNext("2")subject .subscribe { event in  print("2) event: /(event.element!) ") } .addDisposableTo(bag)subject.onNext("3")/* 打印結(jié)果：1) event: 1 1) event: 2 2) event: 1 2) event: 2 1) event: 3 2) event: 3 */

不過有一點值得我們注意，因為 ReplaySubject 緩存機(jī)制使用了數(shù)組結(jié)構(gòu)，所以當(dāng)有大量 ReplaySubject 對象時可能導(dǎo)致內(nèi)存暴增。另外，如果緩存對象是圖片等極耗內(nèi)存的資源時也可能導(dǎo)致內(nèi)存問題。所以 ReplaySubject 不可濫用且緩存區(qū)大小應(yīng)該合理進(jìn)行設(shè)置。

Variable

前面提到過 Variable 類型是 BehaviorSubject 的封裝類型，從某種意義上你可以將前者當(dāng)作后者的子類（實際上并不是）。Variable 類型實例的行為與 BehaviorSubject 一致，只不過前者添加了一些自有特性。你可以通過 value 屬性訪問和設(shè)置 Variable 類型實例當(dāng)前的狀態(tài)值，這意味著我們無需調(diào)用 onNext(_:) 了。

作為 BehaviorSubject 封裝后的類型，Variable 在初始化時也需要設(shè)置默認(rèn)值。另外，它發(fā)送數(shù)據(jù)的行為也與 BehaviorSubject 一致：只會給訂閱者重新發(fā)送最近或者初始值。另一個獨有的特性是，Variable 實例是不會觸發(fā) error 事件的。也就是說，你可以訂閱 Variable 實例的錯誤事件，但是你并不能添加一個錯誤事件到實例中。

代碼示例：

var variable = Variable("Initial value")let bag = DisposeBag()variable.value = "New initial value"variable.asObservable() .subscribe { event in  print("1) event: /(event.element!) ") } .addDisposableTo(bag)

總結(jié)

以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對VEVB武林網(wǎng)的支持。