前言

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

在應(yīng)用中 Subject 實(shí)際上同時(shí)扮演了兩個(gè)不同的角色：既是可觀察對(duì)象同時(shí)也是觀察者。這意味著 Subject 實(shí)例對(duì)象既可以接收事件也可以發(fā)送事件。例如，Subject 實(shí)例對(duì)象可以接收 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í)并不包含數(shù)據(jù)，并且只會(huì)給訂閱者發(fā)送后續(xù)數(shù)據(jù)。
• BehaviorSubject：創(chuàng)建時(shí)需要包含初始數(shù)據(jù)，并且會(huì)給訂閱者發(fā)送后續(xù)數(shù)據(jù)和最近的一次數(shù)據(jù)。
• ReplaySubject：創(chuàng)建時(shí)需要指定對(duì)象緩存區(qū)容量，該容量表示會(huì)給訂閱者重新發(fā)送訂閱前數(shù)據(jù)的大小。
• Variable：BehaviorSubject 對(duì)象的封裝類型。它會(huì)將當(dāng)前數(shù)據(jù)保存為狀態(tài)并且只會(huì)給訂閱者重新發(fā)送最近或者初始值。

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

PublishSubject

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

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

對(duì)應(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) 1
1) 2
2) 2
1) 3
2) 3
*/

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

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

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

另外，當(dāng) PublishSubject 對(duì)象生命周期結(jié)束時(shí)，無論后續(xù)是否繼續(xù)有數(shù)據(jù)產(chǎn)生該對(duì)象只會(huì)簡單的發(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) completed
3) completed
 */

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

BehaviorSubject

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

圖示中最上面對(duì)應(yīng)的是所發(fā)射的數(shù)據(jù)，其中第二行表示第一個(gè)觀察者，第三行則表示另一個(gè)。可以發(fā)現(xiàn)第一個(gè)觀察者是在 1 之后 2 之前進(jìn)行觀察的，但是它依然能夠獲取到數(shù)據(jù) 1 。我們可以通過代碼進(jìn)行驗(yà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")

因?yàn)槭冀K都能獲取到最近的數(shù)據(jù)，所以對(duì)于那些可能需要默認(rèn)值的場景，BehaviorSubject 顯然是一個(gè)好的選擇。

ReplaySubject

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

下圖就是一個(gè) buffer 大小為 2 的 ReplaySubject 對(duì)象。它總過發(fā)射了三次數(shù)據(jù)，其中第一個(gè)觀察者獲取了所以的數(shù)據(jù)。而第二個(gè)觀察者雖然是在第二個(gè)數(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 
*/

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

Variable

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

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

代碼示例：

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)容對(duì)大家的學(xué)習(xí)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對(duì)腳本之家的支持。

最新評(píng)論