前言

RxSwift中Subject是一種非常特殊的序列協(xié)議握爷，全局搜索class Subject / struct Subject都無結(jié)果肃拜，搜索protocol Subject獲取到SubjectType協(xié)議淘正，其中有asObserver方法璧亚，并且遵循ObservableType ->遵循->ObservableConvertibleType， 也就有了asObservable方法结闸。

SujectType

1、PublishSubject

先來看一段使用的示例代碼：

      // 1:初始化序列
        let publishSub = PublishSubject<Int>() //初始化一個(gè)PublishSubject 裝著Int類型的序列
        // 2:發(fā)送響應(yīng)序列
        publishSub.onNext(1)
        // 3:訂閱序列
        publishSub.subscribe { print("訂閱到了:", $0) }
            .disposed(by: disposbag)
        // 再次發(fā)送響應(yīng)
        publishSub.onNext(2)
        publishSub.onNext(3)
//輸出：訂閱到了: next(2)
//訂閱到了: next(3)

查看輸出外永，只打印了2和3崎脉，那為什么1沒有打印呢？
上一篇文章RxSwift - 高階函數(shù)中關(guān)于publish的使用分析伯顶，其中publish就是對(duì)PublishSubject的封裝囚灼，證明了publish就是將多個(gè)觀察者交由唯一的PublishSubject來管理，PublishSubject將所有觀察者.on方法保存祭衩，并順序地響應(yīng)外界的訂閱事件灶体。
那么此處關(guān)于1為響應(yīng)的問題，還是得分析訂閱.subscribe及PublishSubject.on關(guān)鍵代碼：

subscribe

PublishSubject.on

2殖妇、BehaviorSubject

        let behaviorSub = BehaviorSubject.init(value: 100)
        // 2:發(fā)送信號(hào)
        //behaviorSub.onNext(2)
        //behaviorSub.onNext(3)
        // 3:訂閱序列
        behaviorSub.subscribe{ print("訂閱到了1:", $0) }
            .disposed(by: disposbag)
        // 再次發(fā)送
        //behaviorSub.onNext(4)
        //behaviorSub.onNext(5)
        // 再次訂閱
        behaviorSub.subscribe{ print("訂閱到了:", $0) }
            .disposed(by: disposbag)
//輸出：訂閱到了1: next(100)
//訂閱到了: next(100)

此時(shí)代碼中的2刁笙、3、4谦趣、5都是已注釋狀態(tài)疲吸，那么訂閱之后會(huì)響應(yīng)初始值100。
打開2前鹅、3的注釋結(jié)果打诱病：

訂閱到了1: next(3)
訂閱到了: next(3)

說明此時(shí)響應(yīng)了最新的序列元素3。
接著打開4舰绘、5的注釋結(jié)果打吁逵鳌：

訂閱到了1: next(3)
訂閱到了1: next(4)
訂閱到了1: next(5)
訂閱到了: next(5)

此時(shí)可以理解為，在第一次訂閱之前的只響應(yīng)最新的捂寿，但訂閱之后的都會(huì)響應(yīng)口四，第二次訂閱響應(yīng)了之前最新的序列5。
問題一：為什么會(huì)有初始值秦陋，且會(huì)保存最新的值蔓彩？
問題二：相對(duì)于PublishSubject沒有訂閱就無法響應(yīng)的問題，BehaviorSubject怎么能響應(yīng)訂閱之前的事件驳概？
查看BehaviorSubject初始化方法：

BehaviorSubject初始化

element賦最新值

接著我們來看訂閱之后都干了什么：

.subscribe

3锐锣、ReplaySubject

let replaySub = ReplaySubject<Int>.create(bufferSize: 2)
        // let replaySub = ReplaySubject<Int>.createUnbounded()

        // 2:發(fā)送信號(hào)
        replaySub.onNext(1)
        replaySub.onNext(2)
        replaySub.onNext(3)
        replaySub.onNext(4)

        // 3:訂閱序列
        replaySub.subscribe{ print("訂閱到了:", $0) }
            .disposed(by: disposbag)
        // 再次發(fā)送
        replaySub.onNext(7)
        replaySub.onNext(8)
        replaySub.onNext(9)
//輸出：訂閱到了: next(3)
//訂閱到了: next(4)
//訂閱到了: next(7)
//訂閱到了: next(8)
//訂閱到了: next(9)

能打印3腌闯、4以及對(duì)應(yīng)bufferSize: 2可知，會(huì)保存下最新的有效的兩次序列元素雕憔。
我們直接來到.create方法：

.create

ReplayBufferBase

synchronized_on

override func addValueToBuffer(_ value: Element) {
        self.value = value
    }

override func addValueToBuffer(_ value: Element) {
        self.queue.enqueue(value)
    }

ReplayOne只是將當(dāng)前值保存在屬性self.value中悦施，當(dāng)訂閱發(fā)起時(shí)就會(huì)調(diào)用.replayBuffer方法，便會(huì)執(zhí)行當(dāng)先觀察者.on觸發(fā)事件去团，并將當(dāng)前保存的value發(fā)射出去：

ReplayOne

ReplayManyBase則是將值保存在值保存在一個(gè)集合屬性中抡诞，通過添加及更新集合中的元素來達(dá)到只緩存相應(yīng)個(gè)數(shù)的元素。當(dāng)訂閱發(fā)起時(shí)土陪，就會(huì)從集合中將觀察者一個(gè)一個(gè)拿出來觸發(fā).on方法昼汗。

ReplayManyBase.replayBuffer

dispatch

4、AsyncSubject

// 1:創(chuàng)建序列
        let asynSub = AsyncSubject<Int>.init()
        // 2:發(fā)送信號(hào)
        asynSub.onNext(1)
        asynSub.onNext(2)
        // 3:訂閱序列
        asynSub.subscribe{ print("訂閱到了:", $0) }
            .disposed(by: disposbag)
        // 再次發(fā)送
        asynSub.onNext(3)
        asynSub.onNext(4)
        asynSub.onError(NSError.init(domain: "LcrError", code: 10085, userInfo: nil))
        asynSub.onCompleted()
//輸出：訂閱到了: error(Error Domain=LcrError Code=10085 "(null)")

發(fā)現(xiàn)當(dāng)有錯(cuò)誤響應(yīng)時(shí)约啊，前面的響應(yīng)都無效了邑遏。
將錯(cuò)誤注釋，再次打印結(jié)果為:

訂閱到了: next(4)
訂閱到了: completed

然后再給onCompleted添加注釋恰矩，發(fā)現(xiàn)沒有打印任何東西记盒。
里面的工作原理是怎樣的呢？
我們把目光聚集在.on方法上：

.on

synchronized_on

所以一定需要有.completed來且不能發(fā)射錯(cuò)誤骡尽，才能正常響應(yīng)訂閱信息遣妥。

5、BehaviorRelay

Variable : 5.0已經(jīng)廢棄(BehaviorRelay 替換)

// 1:創(chuàng)建序列
        let variableSub = BehaviorRelay.init(value: 1)
        // 2:發(fā)送信號(hào)
        variableSub.accept(100)
        variableSub.accept(10)
        // 3:訂閱信號(hào)
        variableSub.asObservable().subscribe{ print("訂閱到了:", $0) }
            .disposed(by: disposbag)
        print("打印:\(variableSub.value)")
        // 再次發(fā)送
        variableSub.accept(1000)
//輸出：訂閱到了: next(10)
//打印:10
//訂閱到了: next(1000)

BehaviorRelay不僅可以緩存最新的元素攀细，還可以通過屬性訪問到最新緩存的元素箫踩。

BehaviorRelay

源碼可知，BehaviorRelay就是內(nèi)部封裝了一個(gè)BehaviorSubject類型的序列subject谭贪，利用BehaviorSubject能緩存以及能訪問屬性value的特性來實(shí)現(xiàn)屬性訪問境钟。