diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/ignoreElements.ts')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/ignoreElements.ts | 54 |
1 files changed, 0 insertions, 54 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/ignoreElements.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/ignoreElements.ts deleted file mode 100644 index 9e8e32c890..0000000000 --- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/ignoreElements.ts +++ /dev/null @@ -1,54 +0,0 @@ -import { Observable } from '../Observable'; -import { Operator } from '../Operator'; -import { Subscriber } from '../Subscriber'; -import { OperatorFunction } from '../types'; - -/** - * Ignores all items emitted by the source Observable and only passes calls of `complete` or `error`. - * - * ![](ignoreElements.png) - * - * ## Examples - * ### Ignores emitted values, reacts to observable's completion. - * ```javascript - * import { of } from 'rxjs'; - * import { ifnoreElements } from 'rxjs/operators'; - * - * of('you', 'talking', 'to', 'me').pipe( - * ignoreElements(), - * ) - * .subscribe( - * word => console.log(word), - * err => console.log('error:', err), - * () => console.log('the end'), - * ); - * // result: - * // 'the end' - * ``` - * @return {Observable} An empty Observable that only calls `complete` - * or `error`, based on which one is called by the source Observable. - * @method ignoreElements - * @owner Observable - */ -export function ignoreElements(): OperatorFunction<any, never> { - return function ignoreElementsOperatorFunction(source: Observable<any>) { - return source.lift(new IgnoreElementsOperator()); - }; -} - -class IgnoreElementsOperator<T, R> implements Operator<T, R> { - call(subscriber: Subscriber<R>, source: any): any { - return source.subscribe(new IgnoreElementsSubscriber(subscriber)); - } -} - -/** - * We need this JSDoc comment for affecting ESDoc. - * @ignore - * @extends {Ignored} - */ -class IgnoreElementsSubscriber<T> extends Subscriber<T> { - protected _next(unused: T): void { - // Do nothing - } -} |