RxSwift 之 Subject

Cover

上一篇文章介紹了 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：

1. PublishSubject：初始化時並不包含數據，而且只會給訂閱者發送後續數據。
2. BehaviorSubject：建立時須要包含初始數據，而且會給訂閱者發送後續數據和最近的一次數據。
3. ReplaySubject：建立時須要指定對象緩存區容量，該容量表示會給訂閱者從新發送訂閱前數據的大小。
4. Variable：BehaviorSubject 對象的封裝類型。它會將當前數據保存爲狀態而且只會給訂閱者從新發送最近或者初始值。

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

PublishSubject

若是你僅僅是想讓訂閱者獲取被觀察者在生命週期內若產生的數據的話，那麼你徹底能夠選用 PublishSubject 。並且 PublishSubject 對象的行爲符合正常的預期，它只會給訂閱者發送其訂閱開始以後的數據。

例如，下圖的最上面的時間線表示被觀察者所發送的事件，而下面兩個則分別表明不一樣的觀察者。能夠看到下面兩個觀察者都只會接收到訂閱後所發送的事件而沒法獲知以前的情形。

01

對應的代碼爲：

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) 1 1) 2 2) 2 1) 3 2) 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) completed 3) completed */複製代碼

對於時序敏感的操做來講，PublishSubject 顯然是很是合適的選擇。可是並非全部的情形都時序敏感，有時候咱們可能會但願在訂閱時可以獲知最近一次的數據。此時，咱們就須要使用 BehaviorSubject 對象了。

BehaviorSubject

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

02

圖示中最上面對應的是所發射的數據，其中第二行表示第一個觀察者，第三行則表示另外一個。能夠發現第一個觀察者是在 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 對象。它總過發射了三次數據，其中第一個觀察者獲取了因此的數據。而第二個觀察者雖然是在第二個數據發射後纔開始，但它依舊能獲取緩存區中保存的數據。

03

代碼表示以下：

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)複製代碼

原文地址