c02f86fb51af5532a75b3463882fe7d878b6ebeeb32356c67232bef6ac7978159211fd151da484ae40bef0dd4a2b062b374836b52980997d70ea0813525414 3.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. import { merge as mergeStatic } from '../observable/merge';
  2. import { Observable } from '../Observable';
  3. import { ObservableInput, OperatorFunction, MonoTypeOperatorFunction, SchedulerLike } from '../types';
  4. /* tslint:disable:max-line-length */
  5. /** @deprecated Deprecated in favor of static merge. */
  6. export function merge<T>(scheduler?: SchedulerLike): MonoTypeOperatorFunction<T>;
  7. /** @deprecated Deprecated in favor of static merge. */
  8. export function merge<T>(concurrent?: number, scheduler?: SchedulerLike): MonoTypeOperatorFunction<T>;
  9. /** @deprecated Deprecated in favor of static merge. */
  10. export function merge<T, T2>(v2: ObservableInput<T2>, scheduler?: SchedulerLike): OperatorFunction<T, T | T2>;
  11. /** @deprecated Deprecated in favor of static merge. */
  12. export function merge<T, T2>(v2: ObservableInput<T2>, concurrent?: number, scheduler?: SchedulerLike): OperatorFunction<T, T | T2>;
  13. /** @deprecated Deprecated in favor of static merge. */
  14. export function merge<T, T2, T3>(v2: ObservableInput<T2>, v3: ObservableInput<T3>, scheduler?: SchedulerLike): OperatorFunction<T, T | T2 | T3>;
  15. /** @deprecated Deprecated in favor of static merge. */
  16. export function merge<T, T2, T3>(v2: ObservableInput<T2>, v3: ObservableInput<T3>, concurrent?: number, scheduler?: SchedulerLike): OperatorFunction<T, T | T2 | T3>;
  17. /** @deprecated Deprecated in favor of static merge. */
  18. export function merge<T, T2, T3, T4>(v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, scheduler?: SchedulerLike): OperatorFunction<T, T | T2 | T3 | T4>;
  19. /** @deprecated Deprecated in favor of static merge. */
  20. export function merge<T, T2, T3, T4>(v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, concurrent?: number, scheduler?: SchedulerLike): OperatorFunction<T, T | T2 | T3 | T4>;
  21. /** @deprecated Deprecated in favor of static merge. */
  22. export function merge<T, T2, T3, T4, T5>(v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>, scheduler?: SchedulerLike): OperatorFunction<T, T | T2 | T3 | T4 | T5>;
  23. /** @deprecated Deprecated in favor of static merge. */
  24. export function merge<T, T2, T3, T4, T5>(v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>, concurrent?: number, scheduler?: SchedulerLike): OperatorFunction<T, T | T2 | T3 | T4 | T5>;
  25. /** @deprecated Deprecated in favor of static merge. */
  26. export function merge<T, T2, T3, T4, T5, T6>(v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>, v6: ObservableInput<T6>, scheduler?: SchedulerLike): OperatorFunction<T, T | T2 | T3 | T4 | T5 | T6>;
  27. /** @deprecated Deprecated in favor of static merge. */
  28. export function merge<T, T2, T3, T4, T5, T6>(v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>, v6: ObservableInput<T6>, concurrent?: number, scheduler?: SchedulerLike): OperatorFunction<T, T | T2 | T3 | T4 | T5 | T6>;
  29. /** @deprecated Deprecated in favor of static merge. */
  30. export function merge<T>(...observables: Array<ObservableInput<T> | SchedulerLike | number>): MonoTypeOperatorFunction<T>;
  31. /** @deprecated Deprecated in favor of static merge. */
  32. export function merge<T, R>(...observables: Array<ObservableInput<any> | SchedulerLike | number>): OperatorFunction<T, R>;
  33. /* tslint:enable:max-line-length */
  34. /**
  35. * @deprecated Deprecated in favor of static {@link merge}.
  36. */
  37. export function merge<T, R>(...observables: Array<ObservableInput<any> | SchedulerLike | number>): OperatorFunction<T, R> {
  38. return (source: Observable<T>) => source.lift.call(mergeStatic(source, ...observables));
  39. }