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/raceWith.ts | 40 ---------------------- 1 file changed, 40 deletions(-) delete mode 100644 node_modules/rxjs/src/internal/operators/raceWith.ts (limited to 'node_modules/rxjs/src/internal/operators/raceWith.ts') diff --git a/node_modules/rxjs/src/internal/operators/raceWith.ts b/node_modules/rxjs/src/internal/operators/raceWith.ts deleted file mode 100644 index 6e72929..0000000 --- a/node_modules/rxjs/src/internal/operators/raceWith.ts +++ /dev/null @@ -1,40 +0,0 @@ -import { OperatorFunction, ObservableInputTuple } from '../types'; -import { raceInit } from '../observable/race'; -import { operate } from '../util/lift'; -import { identity } from '../util/identity'; - -/** - * Creates an Observable that mirrors the first source Observable to emit a next, - * error or complete notification from the combination of the Observable to which - * the operator is applied and supplied Observables. - * - * ## Example - * - * ```ts - * import { interval, map, raceWith } from 'rxjs'; - * - * const obs1 = interval(7000).pipe(map(() => 'slow one')); - * const obs2 = interval(3000).pipe(map(() => 'fast one')); - * const obs3 = interval(5000).pipe(map(() => 'medium one')); - * - * obs1 - * .pipe(raceWith(obs2, obs3)) - * .subscribe(winner => console.log(winner)); - * - * // Outputs - * // a series of 'fast one' - * ``` - * - * @param otherSources Sources used to race for which Observable emits first. - * @return A function that returns an Observable that mirrors the output of the - * first Observable to emit an item. - */ -export function raceWith( - ...otherSources: [...ObservableInputTuple] -): OperatorFunction { - return !otherSources.length - ? identity - : operate((source, subscriber) => { - raceInit([source, ...otherSources])(subscriber); - }); -} -- cgit v1.2.3