iOS RXSwift 5.12

sample

不定期的对 Observable 取样

sample 操作符将不定期的对源 Observable 进行取样操作。通过第二个 Observable 来控制取样时机。一旦第二个 Observable 发出一个元素，就从源 Observable 中取出最后产生的元素。

retry

如果源 Observable 产生一个错误事件，重新对它进行订阅，希望它不会再次产生错误

retry 操作符将不会将 error 事件，传递给观察者，然而，它会从新订阅源 Observable，给这个 Observable 一个重试的机会，让它有机会不产生 error 事件。retry 总是对观察者发出 next 事件，即便源序列产生了一个 error 事件，所以这样可能会产生重复的元素（如上图所示）。

演示 1

let disposeBag = DisposeBag()
var count = 1

let sequenceThatErrors = Observable<String>.create { observer in

    observer.onNext("🍎")

    observer.onNext("🍐")

    observer.onNext("🍊")

if count == 1 {

        observer.onError(TestError.test)
print("Error encountered")
count += 1

    }


    observer.onNext("🐶")

    observer.onNext("🐱")

    observer.onNext("🐭")

    observer.onCompleted()

return Disposables.create()

}


sequenceThatErrors

    .retry()

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

    .disposed(by: disposeBag)

输出结果：

🍎

🍐

🍊
Error encountered

🍎

🍐

🍊

🐶

🐱

🐭

演示 2

let disposeBag = DisposeBag()
var count = 1

let sequenceThatErrors = Observable<String>.create { observer in

    observer.onNext("🍎")

    observer.onNext("🍐")

    observer.onNext("🍊")

if count < 5 {

        observer.onError(TestError.test)
print("Error encountered")
count += 1

    }


    observer.onNext("🐶")

    observer.onNext("🐱")

    observer.onNext("🐭")

    observer.onCompleted()

return Disposables.create()

}


sequenceThatErrors

    .retry(3)

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

    .disposed(by: disposeBag)

输出结果：

🍎

🍐

🍊
Error encountered

🍎

🍐

🍊
Error encountered

🍎

🍐

🍊
Error encountered
Unhandled error happened: test

 subscription called from:

replay

确保观察者接收到同样的序列，即使是在 Observable 发出元素后才订阅

可被连接的 Observable 和普通的 Observable 十分相似，不过在被订阅后不会发出元素，直到 connect 操作符被应用为止。这样一来你可以控制 Observable 在什么时候开始发出元素。

replay 操作符将 Observable 转换为可被连接的 Observable，并且这个可被连接的 Observable 将缓存最新的 n 个元素。当有新的观察者对它进行订阅时，它就把这些被缓存的元素发送给观察者。

演示

let intSequence = Observable<Int>.interval(1, scheduler: MainScheduler.instance)

    .replay(5)

_ = intSequence

    .subscribe(onNext: { print("Subscription 1:, Event: \($0)") })

DispatchQueue.main.asyncAfter(deadline: .now() + 2) {
_ = intSequence.connect()

}

DispatchQueue.main.asyncAfter(deadline: .now() + 4) {
_ = intSequence

      .subscribe(onNext: { print("Subscription 2:, Event: \($0)") })

}

DispatchQueue.main.asyncAfter(deadline: .now() + 8) {
_ = intSequence

      .subscribe(onNext: { print("Subscription 3:, Event: \($0)") })

}

输出结果：

Subscription 1:, Event: 0
Subscription 2:, Event: 0
Subscription 1:, Event: 1
Subscription 2:, Event: 1
Subscription 1:, Event: 2
Subscription 2:, Event: 2
Subscription 1:, Event: 3
Subscription 2:, Event: 3
Subscription 1:, Event: 4
Subscription 2:, Event: 4
Subscription 3:, Event: 0
Subscription 3:, Event: 1
Subscription 3:, Event: 2
Subscription 3:, Event: 3
Subscription 3:, Event: 4
Subscription 1:, Event: 5
Subscription 2:, Event: 5
Subscription 3:, Event: 5
Subscription 1:, Event: 6
Subscription 2:, Event: 6
Subscription 3:, Event: 6

...