前言

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

在應用中 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 對象的封裝類型。它會將當前數(shù)據(jù)保存為狀態(tài)并且只會給訂閱者重新發(fā)送最近或者初始值。

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

PublishSubject

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

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

對應的代碼為：

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) 1
1) 2
2) 2
1) 3
2) 3
*/

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

subscriptionOne.dispose()
subject.on(.next("4")) 

 /* 打印結(jié)果
 2) 4
 */

另外，當 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()
// 重新進行訂閱操作 
subject
 .subscribe { 
  print("3)", $0.element ?? $0) 
 } 
 .addDisposableTo(disposeBag)
// 發(fā)送新數(shù)據(jù)
subject.onNext("?")

/* 打印結(jié)果
2) completed
3) completed
 */

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

BehaviorSubject

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

圖示中最上面對應的是所發(fā)射的數(shù)據(jù)，其中第二行表示第一個觀察者，第三行則表示另一個?？梢园l(fā)現(xiàn)第一個觀察者是在 1 之后 2 之前進行觀察的，但是它依然能夠獲取到數(shù)據(jù) 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")

因為始終都能獲取到最近的數(shù)據(jù)，所以對于那些可能需要默認值的場景，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 緩存機制使用了數(shù)組結(jié)構(gòu)，所以當有大量 ReplaySubject 對象時可能導致內(nèi)存暴增。另外，如果緩存對象是圖片等極耗內(nèi)存的資源時也可能導致內(nèi)存問題。所以 ReplaySubject 不可濫用且緩存區(qū)大小應該合理進行設置。

Variable

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

作為 BehaviorSubject 封裝后的類型，Variable 在初始化時也需要設置默認值。另外，它發(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)容對大家的學習或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。

最新評論