Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
dom	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
ArrayLikeObservable.ts	1.89 KB	-rw-rw-r--	2022-08-30 11:49
ArrayObservable.ts	4.29 KB	-rw-rw-r--	2022-08-30 11:49
BoundCallbackObservable.ts	14.32 KB	-rw-rw-r--	2022-08-30 11:49
BoundNodeCallbackObservable.ts	12.27 KB	-rw-rw-r--	2022-08-30 11:49
ConnectableObservable.ts	5.58 KB	-rw-rw-r--	2022-08-30 11:49
DeferObservable.ts	3.3 KB	-rw-rw-r--	2022-08-30 11:49
EmptyObservable.ts	2.51 KB	-rw-rw-r--	2022-08-30 11:49
ErrorObservable.ts	2.61 KB	-rw-rw-r--	2022-08-30 11:49
ForkJoinObservable.ts	10.66 KB	-rw-rw-r--	2022-08-30 11:49
FromEventObservable.ts	10.89 KB	-rw-rw-r--	2022-08-30 11:49
FromEventPatternObservable.ts	3.71 KB	-rw-rw-r--	2022-08-30 11:49
FromObservable.ts	4.34 KB	-rw-rw-r--	2022-08-30 11:49
GenerateObservable.ts	9.73 KB	-rw-rw-r--	2022-08-30 11:49
IfObservable.ts	1.84 KB	-rw-rw-r--	2022-08-30 11:49
IntervalObservable.ts	2.67 KB	-rw-rw-r--	2022-08-30 11:49
IteratorObservable.ts	3.69 KB	-rw-rw-r--	2022-08-30 11:49
NeverObservable.ts	1.6 KB	-rw-rw-r--	2022-08-30 11:49
PairsObservable.ts	2.63 KB	-rw-rw-r--	2022-08-30 11:49
PromiseObservable.ts	3.87 KB	-rw-rw-r--	2022-08-30 11:49
RangeObservable.ts	2.87 KB	-rw-rw-r--	2022-08-30 11:49
ScalarObservable.ts	1.32 KB	-rw-rw-r--	2022-08-30 11:49
SubscribeOnObservable.ts	1.51 KB	-rw-rw-r--	2022-08-30 11:49
TimerObservable.ts	3.8 KB	-rw-rw-r--	2022-08-30 11:49
UsingObservable.ts	1.88 KB	-rw-rw-r--	2022-08-30 11:49
bindCallback.ts	131 B	-rw-rw-r--	2022-08-30 11:49
bindNodeCallback.ts	147 B	-rw-rw-r--	2022-08-30 11:49
combineLatest.ts	9.79 KB	-rw-rw-r--	2022-08-30 11:49
concat.ts	6.04 KB	-rw-rw-r--	2022-08-30 11:49
defer.ts	100 B	-rw-rw-r--	2022-08-30 11:49
empty.ts	100 B	-rw-rw-r--	2022-08-30 11:49
forkJoin.ts	112 B	-rw-rw-r--	2022-08-30 11:49
from.ts	96 B	-rw-rw-r--	2022-08-30 11:49
fromEvent.ts	116 B	-rw-rw-r--	2022-08-30 11:49
fromEventPattern.ts	144 B	-rw-rw-r--	2022-08-30 11:49
fromPromise.ts	112 B	-rw-rw-r--	2022-08-30 11:49
generate.ts	111 B	-rw-rw-r--	2022-08-30 11:49
if.ts	89 B	-rw-rw-r--	2022-08-30 11:49
interval.ts	112 B	-rw-rw-r--	2022-08-30 11:49
merge.ts	6.14 KB	-rw-rw-r--	2022-08-30 11:49
never.ts	100 B	-rw-rw-r--	2022-08-30 11:49
of.ts	93 B	-rw-rw-r--	2022-08-30 11:49
onErrorResumeNext.ts	133 B	-rw-rw-r--	2022-08-30 11:49
pairs.ts	102 B	-rw-rw-r--	2022-08-30 11:49
race.ts	3.17 KB	-rw-rw-r--	2022-08-30 11:49
range.ts	100 B	-rw-rw-r--	2022-08-30 11:49
throw.ts	101 B	-rw-rw-r--	2022-08-30 11:49
timer.ts	100 B	-rw-rw-r--	2022-08-30 11:49
using.ts	100 B	-rw-rw-r--	2022-08-30 11:49
zip.ts	79 B	-rw-rw-r--	2022-08-30 11:49

Rename

import { Observable, ObservableInput } from '../Observable';
import { IScheduler } from '../Scheduler';
import { ArrayObservable } from './ArrayObservable';
import { isScheduler } from '../util/isScheduler';
import { mergeAll } from '../operators/mergeAll';

/* tslint:disable:max-line-length */
export function merge<T>(v1: ObservableInput<T>, scheduler?: IScheduler): Observable<T>;
export function merge<T>(v1: ObservableInput<T>, concurrent?: number, scheduler?: IScheduler): Observable<T>;
export function merge<T, T2>(v1: ObservableInput<T>, v2: ObservableInput<T2>, scheduler?: IScheduler): Observable<T | T2>;
export function merge<T, T2>(v1: ObservableInput<T>, v2: ObservableInput<T2>, concurrent?: number, scheduler?: IScheduler): Observable<T | T2>;
export function merge<T, T2, T3>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, scheduler?: IScheduler): Observable<T | T2 | T3>;
export function merge<T, T2, T3>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, concurrent?: number, scheduler?: IScheduler): Observable<T | T2 | T3>;
export function merge<T, T2, T3, T4>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, scheduler?: IScheduler): Observable<T | T2 | T3 | T4>;
export function merge<T, T2, T3, T4>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, concurrent?: number, scheduler?: IScheduler): Observable<T | T2 | T3 | T4>;
export function merge<T, T2, T3, T4, T5>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>, scheduler?: IScheduler): Observable<T | T2 | T3 | T4 | T5>;
export function merge<T, T2, T3, T4, T5>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>, concurrent?: number, scheduler?: IScheduler): Observable<T | T2 | T3 | T4 | T5>;
export function merge<T, T2, T3, T4, T5, T6>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>, v6: ObservableInput<T6>, scheduler?: IScheduler): Observable<T | T2 | T3 | T4 | T5 | T6>;
export function merge<T, T2, T3, T4, T5, T6>(v1: ObservableInput<T>, v2: ObservableInput<T2>, v3: ObservableInput<T3>, v4: ObservableInput<T4>, v5: ObservableInput<T5>, v6: ObservableInput<T6>, concurrent?: number, scheduler?: IScheduler): Observable<T | T2 | T3 | T4 | T5 | T6>;
export function merge<T>(...observables: (ObservableInput<T> | IScheduler | number)[]): Observable<T>;
export function merge<T, R>(...observables: (ObservableInput<any> | IScheduler | number)[]): Observable<R>;
/* tslint:enable:max-line-length */
/**
 * Creates an output Observable which concurrently emits all values from every
 * given input Observable.
 *
 * <span class="informal">Flattens multiple Observables together by blending
 * their values into one Observable.</span>
 *
 * <img src="./img/merge.png" width="100%">
 *
 * `merge` subscribes to each given input Observable (as arguments), and simply
 * forwards (without doing any transformation) all the values from all the input
 * Observables to the output Observable. The output Observable only completes
 * once all input Observables have completed. Any error delivered by an input
 * Observable will be immediately emitted on the output Observable.
 *
 * @example <caption>Merge together two Observables: 1s interval and clicks</caption>
 * var clicks = Rx.Observable.fromEvent(document, 'click');
 * var timer = Rx.Observable.interval(1000);
 * var clicksOrTimer = Rx.Observable.merge(clicks, timer);
 * clicksOrTimer.subscribe(x => console.log(x));
 *
 * // Results in the following:
 * // timer will emit ascending values, one every second(1000ms) to console
 * // clicks logs MouseEvents to console everytime the "document" is clicked
 * // Since the two streams are merged you see these happening
 * // as they occur.
 *
 * @example <caption>Merge together 3 Observables, but only 2 run concurrently</caption>
 * var timer1 = Rx.Observable.interval(1000).take(10);
 * var timer2 = Rx.Observable.interval(2000).take(6);
 * var timer3 = Rx.Observable.interval(500).take(10);
 * var concurrent = 2; // the argument
 * var merged = Rx.Observable.merge(timer1, timer2, timer3, concurrent);
 * merged.subscribe(x => console.log(x));
 *
 * // Results in the following:
 * // - First timer1 and timer2 will run concurrently
 * // - timer1 will emit a value every 1000ms for 10 iterations
 * // - timer2 will emit a value every 2000ms for 6 iterations
 * // - after timer1 hits it's max iteration, timer2 will
 * //   continue, and timer3 will start to run concurrently with timer2
 * // - when timer2 hits it's max iteration it terminates, and
 * //   timer3 will continue to emit a value every 500ms until it is complete
 *
 * @see {@link mergeAll}
 * @see {@link mergeMap}
 * @see {@link mergeMapTo}
 * @see {@link mergeScan}
 *
 * @param {...ObservableInput} observables Input Observables to merge together.
 * @param {number} [concurrent=Number.POSITIVE_INFINITY] Maximum number of input
 * Observables being subscribed to concurrently.
 * @param {Scheduler} [scheduler=null] The IScheduler to use for managing
 * concurrency of input Observables.
 * @return {Observable} an Observable that emits items that are the result of
 * every input Observable.
 * @static true
 * @name merge
 * @owner Observable
 */
export function merge<T, R>(...observables: Array<ObservableInput<any> | IScheduler | number>): Observable<R> {
 let concurrent = Number.POSITIVE_INFINITY;
 let scheduler: IScheduler = null;
  let last: any = observables[observables.length - 1];
  if (isScheduler(last)) {
    scheduler = <IScheduler>observables.pop();
    if (observables.length > 1 && typeof observables[observables.length - 1] === 'number') {
      concurrent = <number>observables.pop();
    }
  } else if (typeof last === 'number') {
    concurrent = <number>observables.pop();
  }

if (scheduler === null && observables.length === 1 && observables[0] instanceof Observable) {
    return <Observable<R>>observables[0];
  }

return mergeAll(concurrent)(new ArrayObservable(<any>observables, scheduler)) as Observable<R>;
}