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/combineLatest.ts | 34 ++++++++++++++++++++++ 1 file changed, 34 insertions(+) create mode 100644 node_modules/rxjs/src/internal/operators/combineLatest.ts (limited to 'node_modules/rxjs/src/internal/operators/combineLatest.ts') diff --git a/node_modules/rxjs/src/internal/operators/combineLatest.ts b/node_modules/rxjs/src/internal/operators/combineLatest.ts new file mode 100644 index 0000000..3f0f3a6 --- /dev/null +++ b/node_modules/rxjs/src/internal/operators/combineLatest.ts @@ -0,0 +1,34 @@ +import { combineLatestInit } from '../observable/combineLatest'; +import { ObservableInput, ObservableInputTuple, OperatorFunction } from '../types'; +import { operate } from '../util/lift'; +import { argsOrArgArray } from '../util/argsOrArgArray'; +import { mapOneOrManyArgs } from '../util/mapOneOrManyArgs'; +import { pipe } from '../util/pipe'; +import { popResultSelector } from '../util/args'; + +/** @deprecated Replaced with {@link combineLatestWith}. Will be removed in v8. */ +export function combineLatest( + sources: [...ObservableInputTuple], + project: (...values: [T, ...A]) => R +): OperatorFunction; +/** @deprecated Replaced with {@link combineLatestWith}. Will be removed in v8. */ +export function combineLatest(sources: [...ObservableInputTuple]): OperatorFunction; + +/** @deprecated Replaced with {@link combineLatestWith}. Will be removed in v8. */ +export function combineLatest( + ...sourcesAndProject: [...ObservableInputTuple, (...values: [T, ...A]) => R] +): OperatorFunction; +/** @deprecated Replaced with {@link combineLatestWith}. Will be removed in v8. */ +export function combineLatest(...sources: [...ObservableInputTuple]): OperatorFunction; + +/** + * @deprecated Replaced with {@link combineLatestWith}. Will be removed in v8. + */ +export function combineLatest(...args: (ObservableInput | ((...values: any[]) => R))[]): OperatorFunction { + const resultSelector = popResultSelector(args); + return resultSelector + ? pipe(combineLatest(...(args as Array>)), mapOneOrManyArgs(resultSelector)) + : operate((source, subscriber) => { + combineLatestInit([source, ...argsOrArgArray(args)])(subscriber); + }); +} -- cgit v1.2.3