diff options
Diffstat (limited to 'node_modules/rxjs/src/internal/operators/merge.ts')
| -rw-r--r-- | node_modules/rxjs/src/internal/operators/merge.ts | 29 |
1 files changed, 0 insertions, 29 deletions
diff --git a/node_modules/rxjs/src/internal/operators/merge.ts b/node_modules/rxjs/src/internal/operators/merge.ts deleted file mode 100644 index 73fff7d..0000000 --- a/node_modules/rxjs/src/internal/operators/merge.ts +++ /dev/null @@ -1,29 +0,0 @@ -import { ObservableInput, ObservableInputTuple, OperatorFunction, SchedulerLike } from '../types'; -import { operate } from '../util/lift'; -import { mergeAll } from './mergeAll'; -import { popNumber, popScheduler } from '../util/args'; -import { from } from '../observable/from'; - -/** @deprecated Replaced with {@link mergeWith}. Will be removed in v8. */ -export function merge<T, A extends readonly unknown[]>(...sources: [...ObservableInputTuple<A>]): OperatorFunction<T, T | A[number]>; -/** @deprecated Replaced with {@link mergeWith}. Will be removed in v8. */ -export function merge<T, A extends readonly unknown[]>( - ...sourcesAndConcurrency: [...ObservableInputTuple<A>, number] -): OperatorFunction<T, T | A[number]>; -/** @deprecated Replaced with {@link mergeWith}. Will be removed in v8. */ -export function merge<T, A extends readonly unknown[]>( - ...sourcesAndScheduler: [...ObservableInputTuple<A>, SchedulerLike] -): OperatorFunction<T, T | A[number]>; -/** @deprecated Replaced with {@link mergeWith}. Will be removed in v8. */ -export function merge<T, A extends readonly unknown[]>( - ...sourcesAndConcurrencyAndScheduler: [...ObservableInputTuple<A>, number, SchedulerLike] -): OperatorFunction<T, T | A[number]>; - -export function merge<T>(...args: unknown[]): OperatorFunction<T, unknown> { - const scheduler = popScheduler(args); - const concurrent = popNumber(args, Infinity); - - return operate((source, subscriber) => { - mergeAll(concurrent)(from([source, ...(args as ObservableInput<T>[])], scheduler)).subscribe(subscriber); - }); -} |
