diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/skip.ts')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/skip.ts | 47 |
1 files changed, 0 insertions, 47 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/skip.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/skip.ts deleted file mode 100644 index b5b7f2a105..0000000000 --- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/skip.ts +++ /dev/null @@ -1,47 +0,0 @@ -import { Operator } from '../Operator'; -import { Subscriber } from '../Subscriber'; -import { Observable } from '../Observable'; -import { MonoTypeOperatorFunction, TeardownLogic } from '../types'; - -/** - * Returns an Observable that skips the first `count` items emitted by the source Observable. - * - * ![](skip.png) - * - * @param {Number} count - The number of times, items emitted by source Observable should be skipped. - * @return {Observable} An Observable that skips values emitted by the source Observable. - * - * @method skip - * @owner Observable - */ -export function skip<T>(count: number): MonoTypeOperatorFunction<T> { - return (source: Observable<T>) => source.lift(new SkipOperator(count)); -} - -class SkipOperator<T> implements Operator<T, T> { - constructor(private total: number) { - } - - call(subscriber: Subscriber<T>, source: any): TeardownLogic { - return source.subscribe(new SkipSubscriber(subscriber, this.total)); - } -} - -/** - * We need this JSDoc comment for affecting ESDoc. - * @ignore - * @extends {Ignored} - */ -class SkipSubscriber<T> extends Subscriber<T> { - count: number = 0; - - constructor(destination: Subscriber<T>, private total: number) { - super(destination); - } - - protected _next(x: T) { - if (++this.count > this.total) { - this.destination.next(x); - } - } -} |