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/startWith.ts | 67 ---------------------- 1 file changed, 67 deletions(-) delete mode 100644 node_modules/rxjs/src/internal/operators/startWith.ts (limited to 'node_modules/rxjs/src/internal/operators/startWith.ts') diff --git a/node_modules/rxjs/src/internal/operators/startWith.ts b/node_modules/rxjs/src/internal/operators/startWith.ts deleted file mode 100644 index 8c11ddb..0000000 --- a/node_modules/rxjs/src/internal/operators/startWith.ts +++ /dev/null @@ -1,67 +0,0 @@ -import { concat } from '../observable/concat'; -import { OperatorFunction, SchedulerLike, ValueFromArray } from '../types'; -import { popScheduler } from '../util/args'; -import { operate } from '../util/lift'; - -// Devs are more likely to pass null or undefined than they are a scheduler -// without accompanying values. To make things easier for (naughty) devs who -// use the `strictNullChecks: false` TypeScript compiler option, these -// overloads with explicit null and undefined values are included. - -export function startWith(value: null): OperatorFunction; -export function startWith(value: undefined): OperatorFunction; - -/** @deprecated The `scheduler` parameter will be removed in v8. Use `scheduled` and `concatAll`. Details: https://rxjs.dev/deprecations/scheduler-argument */ -export function startWith( - ...valuesAndScheduler: [...A, SchedulerLike] -): OperatorFunction>; -export function startWith(...values: A): OperatorFunction>; - -/** - * Returns an observable that, at the moment of subscription, will synchronously emit all - * values provided to this operator, then subscribe to the source and mirror all of its emissions - * to subscribers. - * - * This is a useful way to know when subscription has occurred on an existing observable. - * - * First emits its arguments in order, and then any - * emissions from the source. - * - * ![](startWith.png) - * - * ## Examples - * - * Emit a value when a timer starts. - * - * ```ts - * import { timer, map, startWith } from 'rxjs'; - * - * timer(1000) - * .pipe( - * map(() => 'timer emit'), - * startWith('timer start') - * ) - * .subscribe(x => console.log(x)); - * - * // results: - * // 'timer start' - * // 'timer emit' - * ``` - * - * @param values Items you want the modified Observable to emit first. - * @return A function that returns an Observable that synchronously emits - * provided values before subscribing to the source Observable. - * - * @see {@link endWith} - * @see {@link finalize} - * @see {@link concat} - */ -export function startWith(...values: D[]): OperatorFunction { - const scheduler = popScheduler(values); - return operate((source, subscriber) => { - // Here we can't pass `undefined` as a scheduler, because if we did, the - // code inside of `concat` would be confused by the `undefined`, and treat it - // like an invalid observable. So we have to split it two different ways. - (scheduler ? concat(values, source, scheduler) : concat(values, source)).subscribe(subscriber); - }); -} -- cgit v1.2.3