skip:跳过前几个数据流

  1. import { range } from "rxjs"
  2. import { skip } from "rxjs/operators"
  3. range(1, 10).pipe(skip(5)).subscribe(console.log)

24.png

skipWhile:根据条件进行数据流的跳过

  1. import { range } from "rxjs"
  2. import { skipWhile } from "rxjs/operators"
  3. range(1, 10)
  4. .pipe(skipWhile(n => n < 5))
  5. .subscribe(console.log)

25.png

skipUntil:跳过数据源中前多少时间发出的数据流,发送从这个时间以后数据源中发送的数据流

  1. import { timer, interval } from "rxjs"
  2. import { skipUntil } from "rxjs/operators"
  3. interval(100)
  4. .pipe(skipUntil(timer(2000)))
  5. .subscribe(console.log)

26.png