RxSwift中有四种类型的Subject：

• PublishSubject： 只会发送新的事件给订阅者，订阅之前的事件不会发送。
• BehaviorSubject：有一个初始值，重复发送或者是发送最新的事件给订阅者。
• ReplaySubject：可以指定一个buffer size，它会通过这个buffer 来缓存最近发送的事件，通过buffer size的大小就是缓存事件的个数。当有新的订阅者是，它会把缓存的事件发送给新的订阅者。
• Variable：相当于一个BehaviorSubject的封装，它会保存当前值做为自身的一个状态，发送当前的状态给新的订阅者。

一、PublishSubject

功能解析

PublishSubject 即是一个被观察者（Observable）也是一个观察者 （Observer）

看上面的Marble diagram图：
第一条线是一个PublishSubject，第二、第三条是订阅者，向上的箭头表示订阅者订阅Subject，向下的箭头表示Subject发送事件。
第一个订阅者在1事件发送后才订阅，所以它不会收到1事件，它会收到2.3事件。第二个订阅者在2事件发送出来后才订阅，所以它只会收到3事件。

PublishSubject 的next事件只会发送给当前已经订阅这个subject的订阅者，新的订阅者不会收到订阅之前发送的事件。

Subject终止之后，再去订阅，会给后面的订阅者发送它的终止事件。所有的subject都是如此。

示例代码

example("PublishSubject") { 
    let subject = PublishSubject<String>()
    
    subject.onNext("1")
    
    let subscriptionOne = subject.subscribe(onNext: { (element) in
        print("订阅者一：" + element)
    })
    
    subject.on(.next("2"))
    
    let subscriptionTwo = subject.subscribe(onNext: { (element) in
        print("订阅者二：" + element)
    })
    
    subject.onNext("3")
}

输出：

--- PublishSubject example ---
订阅者一：2
订阅者一：3
订阅者二：3

二、BehaviorSubject

功能解析

BehaviorSubject跟PublishSubject相似，只是它会发送最近的一个next事件给新的订阅者。如上面的Marble diagram：
第一条线是一个BehaviorSubject，第二、第三条是订阅者，向上的箭头表示订阅者订阅Subject，向下的箭头表示Subject发送事件。
第一个订阅者在事件1后订阅subject，它会立马收到最近的一个next事件，也就是1.之后的事件正常接收。
第二个订阅者在事件2后订阅subject，它会立马收到最近的一个next事件，也就是2.之后的事件正常接收。

示例

enum MyError: Error {
    case anError
}

func print<T: CustomStringConvertible>(label: String, event: Event<T>) {
    print(label, event.element ?? event.error ?? event)
}

example("BehaviorSubject") { 
    let subject = BehaviorSubject(value: "1")
    
    let disposeBag = DisposeBag()
    
    subject.subscribe({ (event) in
        
        print(label: "订阅者一：", event: event)
    })
    .disposed(by: disposeBag)
    
    subject.onNext("2")
    
    subject.onError(MyError.anError)
    
    subject.subscribe({ (event) in
        print(label: "订阅者二：", event: event)
    })
    .disposed(by: disposeBag)
}

输出：

--- BehaviorSubject example ---
订阅者一： 1
订阅者一： 2
订阅者一： anError
订阅者二： anError

三、ReplaySubject

功能解析

Replay subjects 可以指定一个buffer size，它会通过这个buffer 来缓存最近发送的事件，通过buffer size的大小就是缓存事件的个数。当有新的订阅者是，它会把缓存的事件发送给新的订阅者。

上面的Marble diagram：
第一条线是一个buffer size为2的ReplaySubject，它会缓存最近的两个事件，第二、第三条是订阅者，向上的箭头表示订阅者订阅Subject，向下的箭头表示Subject发送事件。
第一个订阅者在一开始就订阅了，所以它可以收到，1、2、3事件
第二个订阅者在事件2后面才订阅，因为ReplaySubject的buffer size为2，所以第二个订阅者会立马收到缓存的1、2事件。3事件正常接收。

需要注意的点

ReplaySubject的缓存是缓存在内存里面的，所以，如果ReplaySubject发送的是图片，就不能将buffer size设置的太大，很容易造成内存压力。发送的是数组也一样。所以这里一定要注意内容压力，看类型，不能将buffer size设置过大。

示例

example("ReplaySubject") { 
    let subject = ReplaySubject<String>.create(bufferSize: 2)
    let disposeBag = DisposeBag()
    
    subject.onNext("1")
    subject.onNext("2")
    subject.onNext("3")
    
    subject.subscribe({ (event) in
        print(label: "订阅者一：", event: event)
    })
    .disposed(by: disposeBag)
}

输出：

--- ReplaySubject example ---
订阅者一： 2
订阅者一： 3

四、Variable

功能解析

Variable要指定一个初始值,它会保存当前值做为自身的一个状态，并发送它的初始值或者最新值给新的订阅者。 可以通过它的value属性来读取到它的最新值。
不能给它发送完成或者错误事件，它会在释放的时候自动完成。

示例

example("Variable") { 
    var variable = Variable("1")
    let disposeBag = DisposeBag()
    
    variable.asObservable().subscribe({ (event) in
        print(label: "订阅者一：", event: event)
    })
    .disposed(by: disposeBag)
    
    variable.value = "2"
}

正在系统的学习Swift，RxSwift，欢迎交流！点个关注，不定期更新。