• skip
    • 签名: skip(the: Number): Observable
  • 跳过N个(由参数提供)发出值。
    • 为什么使用 skip
    • 示例
      • 示例 1: 在发送前跳过N个值
    • 示例 2: filter 特定用法的简写形式
  • 其他资源

    skip

    签名: skip(the: Number): Observable

    跳过N个(由参数提供)发出值。

    为什么使用 skip

    skip 允许你忽略源 observable 开头的n个值。通常,当你总是想忽略 observable 的某些值时,应该使用 skip 。或许你不需要这些开头的值,或许你订阅了 ReplayBehaviorSubject 从而不需要初始值。如果你不关心开头的一组值,那就使用 skip 吧。

    你可以使用 filter 加索引来模拟 skip 。例如 .filter((val, index) => index > 1)

    skip - 图1

    示例

    示例 1: 在发送前跳过N个值

    ( jsBin |
    jsFiddle )

    1. import { interval } from 'rxjs/observable/interval';
    2. import { skip } 'rxjs/operators';
    3. // 每1秒发出值
    4. const source = interval(1000);
    5. // 跳过前5个发出值
    6. const example = source.pipe(skip(5));
    7. // 输出: 5...6...7...8........
    8. const subscribe = example.subscribe(val => console.log(val));

    示例 2: filter 特定用法的简写形式

    ( jsBin |
    jsFiddle )

    1. import { from } from 'rxjs/observable/from';
    2. import { skip, filter } 'rxjs/operators';
    3. const numArrayObs = from([1,2,3,4,5,6,7,8,9,10]);
    4. // 3,4,5...
    5. const skipObs = numArrayObs.pipe(skip(2))
    6. .subscribe(console.log);
    7. // 3,4,5...
    8. const filterObs = numArrayObs.pipe(
    9. filter((val, index) => index > 1)
    10. )
    11. .subscribe(console.log);
    12. // 同样的输出!

    其他资源

    • skip :newspaper: - 官方文档
    • 过滤操作符: take, first, skip :video_camera: :dollar: - André Staltz

    :file_folder: 源码: https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/skip.ts