diff options
Diffstat (limited to 'node_modules/rxjs/src/internal/operators/skip.ts')
| -rw-r--r-- | node_modules/rxjs/src/internal/operators/skip.ts | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/node_modules/rxjs/src/internal/operators/skip.ts b/node_modules/rxjs/src/internal/operators/skip.ts new file mode 100644 index 0000000..424ad65 --- /dev/null +++ b/node_modules/rxjs/src/internal/operators/skip.ts @@ -0,0 +1,39 @@ +import { MonoTypeOperatorFunction } from '../types'; +import { filter } from './filter'; + +/** + * Returns an Observable that skips the first `count` items emitted by the source Observable. + * + *  + * + * Skips the values until the sent notifications are equal or less than provided skip count. It raises + * an error if skip count is equal or more than the actual number of emits and source raises an error. + * + * ## Example + * + * Skip the values before the emission + * + * ```ts + * import { interval, skip } from 'rxjs'; + * + * // emit every half second + * const source = interval(500); + * // skip the first 10 emitted values + * const result = source.pipe(skip(10)); + * + * result.subscribe(value => console.log(value)); + * // output: 10...11...12...13... + * ``` + * + * @see {@link last} + * @see {@link skipWhile} + * @see {@link skipUntil} + * @see {@link skipLast} + * + * @param count The number of times, items emitted by source Observable should be skipped. + * @return A function that returns an Observable that skips the first `count` + * values emitted by the source Observable. + */ +export function skip<T>(count: number): MonoTypeOperatorFunction<T> { + return filter((_, index) => count <= index); +} |
