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,欢迎交流!点个关注,不定期更新。
网友评论