iOS RXSwift 5.2

buffer

缓存元素，然后将缓存的元素集合，周期性的发出来

buffer 操作符将缓存 Observable 中发出的新元素，当元素达到某个数量，或者经过了特定的时间，它就会将这个元素集合发送出来。

catchError

从一个错误事件中恢复，将错误事件替换成一个备选序列

catchError 操作符将会拦截一个 error 事件，将它替换成其他的元素或者一组元素，然后传递给观察者。这样可以使得 Observable 正常结束，或者根本都不需要结束。

这里存在其他版本的 catchError 操作符。

演示

let disposeBag = DisposeBag()

let sequenceThatFails = PublishSubject<String>()
let recoverySequence = PublishSubject<String>()


sequenceThatFails

    .catchError {
print("Error:", $0)
return recoverySequence

    }

    .subscribe { print($0) }

    .disposed(by: disposeBag)


sequenceThatFails.onNext("😬")

sequenceThatFails.onNext("😨")

sequenceThatFails.onNext("😡")

sequenceThatFails.onNext("🔴")

sequenceThatFails.onError(TestError.test)


recoverySequence.onNext("😊")

输出结果：

next(😬)

next(😨)

next(😡)

next(🔴)
Error: test

next(😊)

catchErrorJustReturn

catchErrorJustReturn 操作符会将error 事件替换成其他的一个元素，然后结束该序列。

演示

let disposeBag = DisposeBag()
let sequenceThatFails = PublishSubject<String>()


sequenceThatFails

    .catchErrorJustReturn("😊")

    .subscribe { print($0) }

    .disposed(by: disposeBag)


sequenceThatFails.onNext("😬")

sequenceThatFails.onNext("😨")

sequenceThatFails.onNext("😡")

sequenceThatFails.onNext("🔴")

sequenceThatFails.onError(TestError.test)

输出结果：

next(😬)

next(😨)

next(😡)

next(🔴)

next(😊)

completed

combineLatest

当多个 Observables 中任何一个发出一个元素，就发出一个元素。这个元素是由这些 Observables 中最新的元素，通过一个函数组合起来的

combineLatest 操作符将多个 Observables 中最新的元素通过一个函数组合起来，然后将这个组合的结果发出来。这些源 Observables 中任何一个发出一个元素，他都会发出一个元素（前提是，这些 Observables 曾经发出过元素）。

演示

tips: 可与 zip 比较学习

let disposeBag = DisposeBag()

let first = PublishSubject<String>()
let second = PublishSubject<String>()

Observable.combineLatest(first, second) { $0 + $1 }

          .subscribe(onNext: { print($0) })

          .disposed(by: disposeBag)


first.onNext("1")

second.onNext("A")

first.onNext("2")

second.onNext("B")

second.onNext("C")

second.onNext("D")

first.onNext("3")

first.onNext("4")

输出结果：

1A

2A

2B

2C

2D

3D

4D