withLatestFrom

将两个 Observables 最新的元素通过一个函数组合起来，当第一个 Observable 发出一个元素，就将组合后的元素发送出来

withLatestFrom - 图1

withLatestFrom 操作符将两个 Observables 中最新的元素通过一个函数组合起来，然后将这个组合的结果发出来。当第一个 Observable 发出一个元素时，就立即取出第二个 Observable 中最新的元素，通过一个组合函数将两个最新的元素合并后发送出去。

演示

当第一个 Observable 发出一个元素时，就立即取出第二个 Observable 中最新的元素，然后把第二个 Observable 中最新的元素发送出去。

  1. let disposeBag = DisposeBag()
  2. let firstSubject = PublishSubject<String>()
  3. let secondSubject = PublishSubject<String>()
  5. firstSubject
  6.      .withLatestFrom(secondSubject)
  7.      .subscribe(onNext: { print($0) })
  8.      .disposed(by: disposeBag)
  10. firstSubject.onNext("?️")
  11. firstSubject.onNext("?️")
  12. secondSubject.onNext("1")
  13. secondSubject.onNext("2")
  14. firstSubject.onNext("?")

输出结果：

  1. 2

当第一个 Observable 发出一个元素时，就立即取出第二个 Observable 中最新的元素，将第一个 Observable 中最新的元素 first 和第二个 Observable 中最新的元素second组合，然后把组合结果 first+second发送出去。

  1. let disposeBag = DisposeBag()
  2. let firstSubject = PublishSubject<String>()
  3. let secondSubject = PublishSubject<String>()
  5. firstSubject
  6.      .withLatestFrom(secondSubject) {
  7.           (first, second) in
  8.           return first + second
  9.      }
  10.      .subscribe(onNext: { print($0) })
  11.      .disposed(by: disposeBag)
  13. firstSubject.onNext("?️")
  14. firstSubject.onNext("?️")
  15. secondSubject.onNext("1")
  16. secondSubject.onNext("2")
  17. firstSubject.onNext("?")

输出结果：

  1. ?2