前言

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

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

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

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

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

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

PublishSubject

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

例如，下圖的最上面的時間線表示被觀察者所發送的事件，而下面兩個則分別代表不同的觀察者。可以看到下面兩個觀察者都只會接收到訂閱后所發送的事件而無法獲知之前的情形。

對應的代碼為：

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")) /* 打印結果1) 11) 22) 21) 32) 3*/

如果此時我們取消 subscriptionOne 的訂閱并發送新數據的話，那么結果為：

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

另外，當 PublishSubject 對象生命周期結束時，無論后續是否繼續有數據產生該對象只會簡單的發送之前結束生命周期的事件。

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

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

BehaviorSubject

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

圖示中最上面對應的是所發射的數據，其中第二行表示第一個觀察者，第三行則表示另一個。可以發現第一個觀察者是在 1 之后 2 之前進行觀察的，但是它依然能夠獲取到數據 1 。我們可以通過代碼進行驗證：

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")

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

ReplaySubject

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

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

代碼表示如下：

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")/* 打印結果：1) event: 1 1) event: 2 2) event: 1 2) event: 2 1) event: 3 2) event: 3 */

不過有一點值得我們注意，因為 ReplaySubject 緩存機制使用了數組結構，所以當有大量 ReplaySubject 對象時可能導致內存暴增。另外，如果緩存對象是圖片等極耗內存的資源時也可能導致內存問題。所以 ReplaySubject 不可濫用且緩存區大小應該合理進行設置。

Variable

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

作為 BehaviorSubject 封裝后的類型，Variable 在初始化時也需要設置默認值。另外，它發送數據的行為也與 BehaviorSubject 一致：只會給訂閱者重新發送最近或者初始值。另一個獨有的特性是，Variable 實例是不會觸發 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)

總結

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