iOS RXSwift 4.7

ReplaySubject

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("🅱️")

输出结果：

Subscription: 1 Event: next(🐶)
Subscription: 1 Event: next(🐱)
Subscription: 2 Event: next(🐱)
Subscription: 1 Event: next(🅰️)
Subscription: 2 Event: next(🅰️)
Subscription: 1 Event: next(🅱️)
Subscription: 2 Event: next(🅱️)

BehaviorSubject

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

如果源 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("🍊")

输出结果：

Subscription: 1 Event: next(🔴)
Subscription: 1 Event: next(🐶)
Subscription: 1 Event: next(🐱)
Subscription: 2 Event: next(🐱)
Subscription: 1 Event: next(🅰️)
Subscription: 2 Event: next(🅰️)
Subscription: 1 Event: next(🅱️)
Subscription: 2 Event: next(🅱️)
Subscription: 3 Event: next(🅱️)
Subscription: 1 Event: next(🍐)
Subscription: 2 Event: next(🍐)
Subscription: 3 Event: next(🍐)
Subscription: 1 Event: next(🍊)
Subscription: 2 Event: next(🍊)
Subscription: 3 Event: next(🍊)

Variable （已弃用）

Variable 是早期添加到 RxSwift 的概念，通过 “setting” 和 “getting”， 他可以帮助我们从原先命令式的思维方式，过渡到响应式的思维方式。

但这只是我们一厢情愿的想法。许多开发者滥用 Variable，来构建 重度命令式 系统，而不是 Rx 的 声明式 系统。这对于新手很常见，并且他们无法意识到，这是代码的坏味道。所以在 RxSwift 4.x 中 Variable 被轻度弃用，仅仅给出一个运行时警告。

在 RxSwift 5.x 中，他被官方的正式的弃用了，并且在需要时，推荐使用 BehaviorRelay 或者 BehaviorSubject。

ControlProperty

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

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