From d55b767039605256c736166a942a9138e3eacfd7 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sun, 29 Jun 2025 11:49:28 -0700 Subject: remove dev node_modules (oops) --- .../rxjs/src/internal/operators/defaultIfEmpty.ts | 59 ---------------------- 1 file changed, 59 deletions(-) delete mode 100644 node_modules/rxjs/src/internal/operators/defaultIfEmpty.ts (limited to 'node_modules/rxjs/src/internal/operators/defaultIfEmpty.ts') diff --git a/node_modules/rxjs/src/internal/operators/defaultIfEmpty.ts b/node_modules/rxjs/src/internal/operators/defaultIfEmpty.ts deleted file mode 100644 index 9e0d277..0000000 --- a/node_modules/rxjs/src/internal/operators/defaultIfEmpty.ts +++ /dev/null @@ -1,59 +0,0 @@ -import { OperatorFunction } from '../types'; -import { operate } from '../util/lift'; -import { createOperatorSubscriber } from './OperatorSubscriber'; - -/** - * Emits a given value if the source Observable completes without emitting any - * `next` value, otherwise mirrors the source Observable. - * - * If the source Observable turns out to be empty, then - * this operator will emit a default value. - * - * ![](defaultIfEmpty.png) - * - * `defaultIfEmpty` emits the values emitted by the source Observable or a - * specified default value if the source Observable is empty (completes without - * having emitted any `next` value). - * - * ## Example - * - * If no clicks happen in 5 seconds, then emit 'no clicks' - * - * ```ts - * import { fromEvent, takeUntil, interval, defaultIfEmpty } from 'rxjs'; - * - * const clicks = fromEvent(document, 'click'); - * const clicksBeforeFive = clicks.pipe(takeUntil(interval(5000))); - * const result = clicksBeforeFive.pipe(defaultIfEmpty('no clicks')); - * result.subscribe(x => console.log(x)); - * ``` - * - * @see {@link empty} - * @see {@link last} - * - * @param defaultValue The default value used if the source - * Observable is empty. - * @return A function that returns an Observable that emits either the - * specified `defaultValue` if the source Observable emits no items, or the - * values emitted by the source Observable. - */ -export function defaultIfEmpty(defaultValue: R): OperatorFunction { - return operate((source, subscriber) => { - let hasValue = false; - source.subscribe( - createOperatorSubscriber( - subscriber, - (value) => { - hasValue = true; - subscriber.next(value); - }, - () => { - if (!hasValue) { - subscriber.next(defaultValue!); - } - subscriber.complete(); - } - ) - ); - }); -} -- cgit v1.2.3