RxSwift4-Subjects介绍

2021-04-15 本文已影响0人浮华_du

看了前面介绍的创建Observable的方式, 我们应该会想,在项目的实际使用中,大多数情况都是预先不知道序列值的.比如:我们要订阅文本框内容输入的变化.
这个时候,RxSwift为我们提供了Subjects,既是订阅者，也是 Observable.
Subjects分为四种类型: PublishSubject、BehaviorSubject、ReplaySubject、Variable(BehaviorRelay).我们分别来介绍下他们的用法及区别:

1. PublishSubject

无需初始值
订阅者只能收到他们 订阅后 发出的Event.

let subject = PublishSubject<String>()
        subject.onNext("第一条消息")
        subject.subscribe(onNext: { string in
            print("第1次订阅：", string)
        }, onCompleted:{
            print("第1次订阅：onCompleted")
        }).disposed(by: disposeBag)
         
        subject.onNext("第二条消息")
         
        subject.subscribe(onNext: { string in
            print("第2次订阅：", string)
        }, onCompleted:{
            print("第2次订阅：onCompleted")
        }).disposed(by: disposeBag)
         
        subject.onNext("第三条消息")
         
        //让subject结束
        subject.onCompleted()
         
        //subject结束后会发出.next事件了。
        subject.onNext("第四条消息")
         
        subject.subscribe(onNext: { string in
            print("第3次订阅：", string)
        }, onCompleted:{
            print("第3次订阅：onCompleted")
        }).disposed(by: disposeBag)

//第1次订阅： 第二条消息
//第1次订阅： 第三条消息
//第2次订阅： 第三条消息
//第1次订阅：onCompleted
//第2次订阅：onCompleted
//第3次订阅：onCompleted

2. BehaviorSubject

需要传入初始值
当一个订阅者来订阅它的时候，这个订阅者会立即收到 BehaviorSubjects 上一个及之后 发出的新的 event。

let subject = BehaviorSubject(value: "初始消息")
        subject.onNext("第一条消息")
        subject.subscribe(onNext: { string in
            print("第1次订阅：", string)
        }, onCompleted:{
            print("第1次订阅：onCompleted")
        }).disposed(by: disposeBag)
         
        subject.onNext("第二条消息")
         
        subject.subscribe(onNext: { string in
            print("第2次订阅：", string)
        }, onCompleted:{
            print("第2次订阅：onCompleted")
        }).disposed(by: disposeBag)
         
        subject.onNext("第三条消息")
         
        //让subject结束
        subject.onCompleted()
         
        //subject完成后会发出.next事件了。
        subject.onNext("第四条消息")
         
        subject.subscribe(onNext: { string in
            print("第3次订阅：", string)
        }, onCompleted:{
            print("第3次订阅：onCompleted")
        }).disposed(by: disposeBag)

//第1次订阅： 第一条消息
//第1次订阅： 第二条消息
//第2次订阅： 第二条消息
//第1次订阅： 第三条消息
//第2次订阅： 第三条消息
//第1次订阅：onCompleted
//第2次订阅：onCompleted
//第3次订阅：onCompleted

3.ReplaySubject

需要一个初始bufferSize(缓存的event的个数)
当一个订阅者来订阅它的时候，这个订阅者会立即收到 ReplaySubject 最近两个及之后 发出的新的 event。

例如下面代码, 一个 ReplaySubject 的 bufferSize 设置为 2，它发出了 4 个 .next 的 event("第五条消息"是在结束后.onNext的,不会发出)，那么它会将后两个（最近的两个-bufferSize个数）event 给缓存起来。

此时如果有一个 subscriber 订阅了这个 ReplaySubject，那么这个 subscriber 就会立即收到前面缓存的两个.next 的 event。(例如:第三次订阅,收到了前面缓存的最近的两个消息2,3)及之后发出的4消息)

如果一个 subscriber 订阅已经结束的 ReplaySubject，除了会收到缓存的 .next 的 event外，还会收到那个终结的 .error 或者 .complete 的event。(第五次订阅)
//第一次订阅总共收到了 1,+2,3,4消息
//第二次订阅总共收到了 1,2,+3,4消息
//第三次订阅总共收到了 2,3,+4消息
//第四次订阅总共收到了 3,4+无消息
//第五次订阅总共收到了 3,4+无消息

let subject = ReplaySubject<String>.create(bufferSize: 2)
        subject.onNext("第一条消息")
        subject.subscribe(onNext: { string in
            print("第1次订阅：", string)
        }, onCompleted:{
            print("第1次订阅：onCompleted")
        }).disposed(by: disposeBag)
         
        subject.onNext("第二条消息")
         
        subject.subscribe(onNext: { string in
            print("第2次订阅：", string)
        }, onCompleted:{
            print("第2次订阅：onCompleted")
        }).disposed(by: disposeBag)
         
        subject.onNext("第三条消息")
         
        subject.subscribe(onNext: { string in
            print("第3次订阅：", string)
        }, onCompleted:{
            print("第3次订阅：onCompleted")
        }).disposed(by: disposeBag)
        
        subject.onNext("第四条消息")
        
        subject.subscribe(onNext: { string in
            print("第4次订阅：", string)
        }, onCompleted:{
            print("第4次订阅：onCompleted")
        }).disposed(by: disposeBag)
        
        //让subject结束
        subject.onCompleted()
         
        //subject完成后就不会发出.next事件了。
        subject.onNext("第五条消息")
        
        subject.subscribe(onNext: { string in
            print("第5次订阅：", string)
        }, onCompleted:{
            print("第5次订阅：onCompleted")
        }).disposed(by: disposeBag)
//第1次订阅： 第一条消息
//第1次订阅： 第二条消息
//第2次订阅： 第一条消息
//第2次订阅： 第二条消息
//第1次订阅： 第三条消息
//第2次订阅： 第三条消息
//第3次订阅： 第二条消息
//第3次订阅： 第三条消息
//第1次订阅： 第四条消息
//第2次订阅： 第四条消息
//第3次订阅： 第四条消息
//第4次订阅： 第三条消息
//第4次订阅： 第四条消息
//第1次订阅：onCompleted
//第2次订阅：onCompleted
//第3次订阅：onCompleted
//第4次订阅：onCompleted
//第5次订阅： 第三条消息
//第5次订阅： 第四条消息
//第5次订阅：onCompleted

4. Variable => BehaviorRelay

Variable 其实就是对 BehaviorSubject 的封装，所以它也必须要通过一个默认的初始值进行创建。
Variable 具有 BehaviorSubject 的功能，能够向它的订阅者发出上一个 event 以及之后新创建的 event。
不同的是，Variable 还会把当前发出的值保存为自己的状态。同时它会在销毁时自动发送 .complete的 event，不需要也不能手动给 Variables 发送 completed或者 error 事件来结束它。
简单地说就是 Variable 有一个 value 属性，我们改变这个 value 属性的值就相当于调用一般 Subjects 的 onNext() 方法，而这个最新的 onNext() 的值就被保存在 value 属性里了，直到我们再次修改它。
Variable已经被BehaviorRelay取代

 let variable = Variable("初始消息")
        
        variable.value = "第一条消息"
        //第1次订阅
        variable.asObservable().subscribe {
            print("第1次订阅：", $0)
        }.disposed(by: disposeBag)
        
        variable.value = "第二条消息"
        //第2次订阅
        variable.asObservable().subscribe {
            print("第2次订阅：", $0)
        }.disposed(by: disposeBag)
        
        variable.value = "第三条消息"
        variable.asObservable().subscribe {
            print("第3次订阅：", $0)
        }.disposed(by: disposeBag)

//ℹ️ [DEPRECATED] `Variable` is planned for future deprecation. Please consider `BehaviorRelay` as a replacement. Read more at: https://git.io/vNqvx
//第1次订阅： next(第一条消息)
//第1次订阅： next(第二条消息)
//第2次订阅： next(第二条消息)
//第1次订阅： next(第三条消息)
//第2次订阅： next(第三条消息)
//第3次订阅： next(第三条消息)
//第1次订阅： completed
//第2次订阅： completed
//第3次订阅： completed

5. BehaviorRelay

BehaviorRelay 是作为Variable 的替代者出现的。它的本质其实也是对 BehaviorSubject 的封装，所以它也必须要通过一个默认的初始值进行创建。
BehaviorRelay 具有 BehaviorSubject的功能，能够向它的订阅者发出上一个 event 以及之后新创建的 event。
与 BehaviorSubject 不同的是，不需要也不能手动给 BehaviorReply 发送 completed 或者 error 事件来结束它（BehaviorRelay 会在销毁时也不会自动发送 .complete 的 event）。
BehaviorRelay 有一个 value 属性，我们通过这个属性可以获取最新值。而通过它的 accept() 方法可以对值进行修改

let subject = BehaviorRelay<String>(value: "初始值")
        subject.accept("第一条消息")
        subject.asObservable().subscribe {
            print("第1次订阅：", $0)
        }.disposed(by: disposeBag)
        subject.accept("第二条消息")

        subject.asObservable().subscribe {
            print("第2次订阅：", $0)
        }.disposed(by: disposeBag)
        subject.accept("第三条消息")

https://www.jianshu.com/p/def6965b0475
https://blog.csdn.net/qq_30963589/article/details/112171117