首先我們來看看：SubjectType的原理竭翠！

public protocol SubjectType : ObservableType {
      // 關(guān)聯(lián)了觀察者類型，具備這個類型的能力
    associatedtype SubjectObserverType : ObserverType
    func asObserver() -> SubjectObserverType
}

• SubjectType首先就是繼承了ObservableType，具有序列特性
• 關(guān)聯(lián)了觀察者類型，具備這個類型的能力
• 下面我們通過一個具體類型來感受一下subject

// 1:初始化序列
let publishSub = 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)

• 很明顯能夠訂閱信號（序列最基本的能力）
• 能夠發(fā)送響應(yīng)浩聋，又是觀察者的能力

• 查看底層源碼分析

  
  
  1.png

各種Subject
PublishSubject
可以不需要初始來進行初始化（也就是可以為空），并且它只會向訂閱者發(fā)送在訂閱之后才接收到的元素

//1:初始化序列
        let publishSub = PublishSubject<Int>()
        // 2:發(fā)送響應(yīng)序列
        publishSub.onNext(1)
        // 3:訂閱序列
        publishSub.subscribe{print($0)}
        .disposed(by: disposeBag)
        publishSub.onNext(2)
        publishSub.onNext(3)

• 信號:1是無法被訂閱的臊恋，只接受訂閱之后的響應(yīng)

  
  
  PublishSubject 流程

BehaviorSubject
通過一個默認初始值來創(chuàng)建衣洁，當訂閱者訂閱BehaviorSubject時，會收到訂閱后Subject上一個發(fā)出的Event抖仅，如果還沒有收到任何數(shù)據(jù)坊夫，會發(fā)出一個默認值。之后就和PublishSubject一樣撤卢，正常接收新的事件环凿。

• 和publish 稍微不同就是behavior這個家伙有個存儲功能：存儲上一次的信號

let behaviorSub = BehaviorSubject.init(value: 100)
        
        behaviorSub.onNext(101)
        behaviorSub.onNext(102)
        behaviorSub.subscribe{print($0)}.disposed(by: disposeBag)
        behaviorSub.onNext(103)
        behaviorSub.onNext(104)
        behaviorSub.subscribe{print($0)}.disposed(by: disposeBag)

• 當沒有信號的時候，會默認發(fā)送 信號：100
• 只能儲存一個信號：信號2 會被 信號3 覆蓋

• 訂閱信號之前能夠儲存信號

  
  
  BehaviorSubject 流程

ReplaySubject
ReplaySubject 發(fā)送源Observable 的所有事件無論observer什么時候開始訂閱放吩。

// 1:創(chuàng)建序列
let replaySub = ReplaySubject<Int>.create(bufferSize: 2)
// let replaySub = ReplaySubject<Int>.createUnbounded()

// 2:發(fā)送信號
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)

• 一個bufferSize空間智听，想存儲多少次響應(yīng)就是多少次
• 其他流程照舊
• 源碼里面就是相對于BehaviorSubject的儲存屬性變成了集合
  
  replaySubject 流程
  
  之前使用Variable非常順手，但目前已被廢棄渡紫，需使用BehaviorReplay代替
• 替換原來的Variable
• 可以儲存一個信號
• 隨時訂閱響應(yīng)
• 響應(yīng)發(fā)送的時候要注意：behaviorR.accept(20)

let behaviorRelay = BehaviorRelay(value: 100)
behaviorRelay.subscribe(onNext: { (num) in
    print(num)
.disposed(by: disposbag)
print("打印:\(behaviorRelay.value)")

behaviorRelay.accept(1000)