ReplaySubject


ReplaySubject

image

ReplaySubject 将对观察者发送全部的元素,无论观察者是何时进行订阅的。

这里存在多个版本的 ReplaySubject,有的只会将最新的 n 个元素发送给观察者,有的只会将限制时间段内最新的元素发送给观察者。

如果把 ReplaySubject 当作观察者来使用,注意不要在多个线程调用 onNext, onError 或 onCompleted。这样会导致无序调用,将造成意想不到的结果。

let disposeBag = DisposeBag() let subject = ReplaySubject<String>.create(bufferSize: 1)  subject  .subscribe { print("Subscription: 1 Event:", $0) }  .disposed(by: disposeBag)  subject.onNext("🐶") subject.onNext("🐱")  subject  .subscribe { print("Subscription: 2 Event:", $0) }  .disposed(by: disposeBag)  subject.onNext("🅰️") subject.onNext("🅱️")

image

BehaviorSubject

image 当观察者对 BehaviorSubject 进行订阅时,它会将源 Observable 中最新的元素发送出来(如果不存在最新的元素,就发出默认元素)。然后将随后产生的元素发送出来。

image

如果源 Observable 因为产生了一个 error 事件而中止, BehaviorSubject 就不会发出任何元素,而是将这个 error 事件发送出来。

let disposeBag = DisposeBag() let subject = BehaviorSubject(value: "🔴")  subject  .subscribe { print("Subscription: 1 Event:", $0) }  .disposed(by: disposeBag)  subject.onNext("🐶") subject.onNext("🐱")  subject  .subscribe { print("Subscription: 2 Event:", $0) }  .disposed(by: disposeBag)  subject.onNext("🅰️") subject.onNext("🅱️")  subject  .subscribe { print("Subscription: 3 Event:", $0) }  .disposed(by: disposeBag)  subject.onNext("🍐") subject.onNext("🍊") 

image

ControlProperty

ControlProperty 专门用于描述 UI 控件属性的,它具有以下特征:

  • 不会产生 error 事件
  • 一定在 MainScheduler 订阅(主线程订阅)
  • 一定在 MainScheduler 监听(主线程监听)
  • 共享附加作用


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM