From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- .../rxjs/src/internal/operators/ignoreElements.ts | 45 ++++++++++++++++++++++ 1 file changed, 45 insertions(+) create mode 100644 node_modules/rxjs/src/internal/operators/ignoreElements.ts (limited to 'node_modules/rxjs/src/internal/operators/ignoreElements.ts') diff --git a/node_modules/rxjs/src/internal/operators/ignoreElements.ts b/node_modules/rxjs/src/internal/operators/ignoreElements.ts new file mode 100644 index 0000000..d4977ac --- /dev/null +++ b/node_modules/rxjs/src/internal/operators/ignoreElements.ts @@ -0,0 +1,45 @@ +import { OperatorFunction } from '../types'; +import { operate } from '../util/lift'; +import { createOperatorSubscriber } from './OperatorSubscriber'; +import { noop } from '../util/noop'; + +/** + * Ignores all items emitted by the source Observable and only passes calls of `complete` or `error`. + * + * ![](ignoreElements.png) + * + * The `ignoreElements` operator suppresses all items emitted by the source Observable, + * but allows its termination notification (either `error` or `complete`) to pass through unchanged. + * + * If you do not care about the items being emitted by an Observable, but you do want to be notified + * when it completes or when it terminates with an error, you can apply the `ignoreElements` operator + * to the Observable, which will ensure that it will never call its observers’ `next` handlers. + * + * ## Example + * + * Ignore all `next` emissions from the source + * + * ```ts + * import { of, ignoreElements } from 'rxjs'; + * + * of('you', 'talking', 'to', 'me') + * .pipe(ignoreElements()) + * .subscribe({ + * next: word => console.log(word), + * error: err => console.log('error:', err), + * complete: () => console.log('the end'), + * }); + * + * // result: + * // 'the end' + * ``` + * + * @return A function that returns an empty Observable that only calls + * `complete` or `error`, based on which one is called by the source + * Observable. + */ +export function ignoreElements(): OperatorFunction { + return operate((source, subscriber) => { + source.subscribe(createOperatorSubscriber(subscriber, noop)); + }); +} -- cgit v1.2.3