RxSwift发送及订阅 Subjects、Variables代码示例
作者:芬达
这篇文章主要介绍了RxSwift发送及订阅 Subjects、Variables代码示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
Subjects 介绍
1. Subjects 是订阅者,也是Observable
订阅者:它能动态的接收新的值。
Observable: 当Subjects有了新值后会通过Event将新值发出给他的所有订阅者。
2. 常用的方法
- onNext(:):是on(.next(:)) 的简便写法。该方法相当于 subject 接收到一个.next 事件。
- onError(:):是on(.error(:))的简便写法。该方法相当于 subject 接收到一个.error 事件。
- onCompleted():是 on(.completed)的简便写法。该方法相当于 subject 接收到一个 .completed事件。
3. Subjects 有四种PublishSubject、BehaviorSubject、ReplaySubject、Variable
相同点
- 都是Observable,他们的订阅者都能接收他们发出的新的Event
- 直到 Subject 发出 .complete 或者 .error 的 Event 后,该 Subject 便终结了,同时它也就不会再发出.next事件。
- 对于那些在Subject 终结后再订阅他的订阅者,也能收到 subject发出的一条.complete 或.error的event,告诉这个新的订阅者它已经终结了。
不同点
- PublishSubject
- 最普通的Subject,不需要初始值就能初始化。
- 他的订阅者只能收到他们订阅后的 Event。
let sub = PublishSubject<String>() sub.onNext("订阅之前的不能接收到") sub.subscribe { event in print(event.element) //Optional("订阅之后的可以接收到") //nil }.disposed(by: disposeBag) sub.onNext("订阅之后的可以接收到") //结束 sub.onCompleted() /// 结束之后添加的订阅能收到 completed sub.subscribe { event in print(event) } sub.onNext("结束后发的都收不到")
BehaviorSubject
需要一个默认值初始化
当一个订阅者订阅之后会立马收到上一个Event,之后就是正常情况发一个收一个。
onCompleted()之后的订阅者也只能收到Completed。
let sub = BehaviorSubject(value: "默认值") sub.subscribe { event in print("订阅1", event) }.disposed(by: disposeBag) sub.onNext("发送1") sub.subscribe { event in print("订阅2", event) }.disposed(by: disposeBag) sub.onCompleted() sub.subscribe { event in print("订阅3", event) }.disposed(by: disposeBag) 订阅1 next(默认值) 订阅1 next(发送1) 订阅2 next(发送1) 订阅1 completed 订阅2 completed 订阅3 completed
ReplaySubject
创建的时候需要一个参数bufferSize设置记录个数
新添加的订阅会接收到之前发送的两个 Event,如果不足两个就只接收一个。
如果超过两个只接收最新的两个。
如果订阅时已经结束除了会接收到最新的两个Event外还有结束的complete或error。
let sub = ReplaySubject<String>.create(bufferSize: 2) sub.subscribe { event in print("订阅1", event) }.disposed(by: disposeBag) sub.onNext("发送1") print("-------") sub.subscribe { event in print("订阅2", event) }.disposed(by: disposeBag) sub.onNext("发送2") sub.onNext("发送3") sub.onNext("发送4") print("-------") sub.subscribe { event in print("订阅3", event) }.disposed(by: disposeBag) sub.onCompleted() print("-------") /// 不仅会收到最后的两个 event 还有 Completed sub.subscribe { event in print("订阅4", event) } 订阅1 next(发送1) ------- 订阅2 next(发送1) 订阅1 next(发送2) 订阅2 next(发送2) 订阅1 next(发送3) 订阅2 next(发送3) 订阅1 next(发送4) 订阅2 next(发送4) ------- 订阅3 next(发送3) 订阅3 next(发送4) 订阅1 completed 订阅2 completed 订阅3 completed ------- 订阅4 next(发送3) 订阅4 next(发送4) 订阅4 completed
BehaviorRelay
基本同 BehaviorSubject功能一样,但是不能主动调用onCompleted和error,会在BehaviorRelay释放前调用
let sub = BehaviorRelay(value: "初始值") sub.subscribe { event in print("第一次订阅", event) }.disposed(by: disposeBag) sub.accept("新值1") sub.subscribe { event in print("第二次订阅", event) }.disposed(by: disposeBag)
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。