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. ?