diff --git a/compat/operators/concat.ts b/compat/operators/concat.ts new file mode 100644 index 0000000000..2fb1fd3e2e --- /dev/null +++ b/compat/operators/concat.ts @@ -0,0 +1,16 @@ +import { concat as concatStatic, Observable, ObservableInput, OperatorFunction, MonoTypeOperatorFunction, SchedulerLike } from 'rxjs'; + +/* tslint:disable:max-line-length */ +export function concat(scheduler?: SchedulerLike): MonoTypeOperatorFunction; +export function concat(v2: ObservableInput, scheduler?: SchedulerLike): OperatorFunction; +export function concat(v2: ObservableInput, v3: ObservableInput, scheduler?: SchedulerLike): OperatorFunction; +export function concat(v2: ObservableInput, v3: ObservableInput, v4: ObservableInput, scheduler?: SchedulerLike): OperatorFunction; +export function concat(v2: ObservableInput, v3: ObservableInput, v4: ObservableInput, v5: ObservableInput, scheduler?: SchedulerLike): OperatorFunction; +export function concat(v2: ObservableInput, v3: ObservableInput, v4: ObservableInput, v5: ObservableInput, v6: ObservableInput, scheduler?: SchedulerLike): OperatorFunction; +export function concat(...observables: Array | SchedulerLike>): MonoTypeOperatorFunction; +export function concat(...observables: Array | SchedulerLike>): OperatorFunction; +/* tslint:enable:max-line-length */ + +export function concat(...observables: Array | SchedulerLike>): OperatorFunction { + return (source: Observable) => source.lift.call(concatStatic(source, ...observables)); +} diff --git a/legacy-reexport/operators/concat.ts b/legacy-reexport/operators/concat.ts new file mode 100644 index 0000000000..d2b7050940 --- /dev/null +++ b/legacy-reexport/operators/concat.ts @@ -0,0 +1 @@ +export * from 'rxjs-compat/operators/concat'; \ No newline at end of file