From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- node_modules/rxjs/src/internal/operators/concat.ts | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100644 node_modules/rxjs/src/internal/operators/concat.ts (limited to 'node_modules/rxjs/src/internal/operators/concat.ts') diff --git a/node_modules/rxjs/src/internal/operators/concat.ts b/node_modules/rxjs/src/internal/operators/concat.ts new file mode 100644 index 0000000..eadb595 --- /dev/null +++ b/node_modules/rxjs/src/internal/operators/concat.ts @@ -0,0 +1,22 @@ +import { ObservableInputTuple, OperatorFunction, SchedulerLike } from '../types'; +import { operate } from '../util/lift'; +import { concatAll } from './concatAll'; +import { popScheduler } from '../util/args'; +import { from } from '../observable/from'; + +/** @deprecated Replaced with {@link concatWith}. Will be removed in v8. */ +export function concat(...sources: [...ObservableInputTuple]): OperatorFunction; +/** @deprecated Replaced with {@link concatWith}. Will be removed in v8. */ +export function concat( + ...sourcesAndScheduler: [...ObservableInputTuple, SchedulerLike] +): OperatorFunction; + +/** + * @deprecated Replaced with {@link concatWith}. Will be removed in v8. + */ +export function concat(...args: any[]): OperatorFunction { + const scheduler = popScheduler(args); + return operate((source, subscriber) => { + concatAll()(from([source, ...args], scheduler)).subscribe(subscriber); + }); +} -- cgit v1.2.3