skipUntil

跳过 Observable 中头几个元素,直到另一个 Observable 发出一个元素

skipUntil - 图1

skipUntil 操作符可以让你忽略源 Observable 中头几个元素,直到另一个 Observable 发出一个元素后,它才镜像源 Observable


演示

  1. let disposeBag = DisposeBag()
  2. let sourceSequence = PublishSubject<String>()
  3. let referenceSequence = PublishSubject<String>()
  4. sourceSequence
  5. .skipUntil(referenceSequence)
  6. .subscribe(onNext: { print($0) })
  7. .disposed(by: disposeBag)
  8. sourceSequence.onNext("🐱")
  9. sourceSequence.onNext("🐰")
  10. sourceSequence.onNext("🐶")
  11. referenceSequence.onNext("🔴")
  12. sourceSequence.onNext("🐸")
  13. sourceSequence.onNext("🐷")
  14. sourceSequence.onNext("🐵")

输出结果:

  1. 🐸
  2. 🐷
  3. 🐵