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 } from '../Observable';
import { isArray } from '../util/isArray';
import { ArrayObservable } from '../observable/ArrayObservable';
import { Operator } from '../Operator';
import { Subscriber } from '../Subscriber';
import { Subscription, TeardownLogic } from '../Subscription';
import { OuterSubscriber } from '../OuterSubscriber';
import { InnerSubscriber } from '../InnerSubscriber';
import { subscribeToResult } from '../util/subscribeToResult';

/**
 * Returns an Observable that mirrors the first source Observable to emit an item.
 * @param {...Observables} ...observables sources used to race for which Observable emits first.
 * @return {Observable} an Observable that mirrors the output of the first Observable to emit an item.
 * @static true
 * @name race
 * @owner Observable
 */
export function race<T>(observables: Array<Observable<T>>): Observable<T>;
export function race<T>(observables: Array<Observable<any>>): Observable<T>;
export function race<T>(...observables: Array<Observable<T> | Array<Observable<T>>>): Observable<T>;
export function race<T>(...observables: Array<Observable<any> | Array<Observable<any>>>): Observable<T> {
  // if the only argument is an array, it was most likely called with
  // `race([obs1, obs2, ...])`
  if (observables.length === 1) {
    if (isArray(observables[0])) {
      observables = <Array<Observable<any>>>observables[0];
    } else {
      return <Observable<any>>observables[0];
    }
  }

return new ArrayObservable<T>(<any>observables).lift(new RaceOperator<T>());
}

export class RaceOperator<T> implements Operator<T, T> {
  call(subscriber: Subscriber<T>, source: any): TeardownLogic {
    return source.subscribe(new RaceSubscriber(subscriber));
  }
}

/**
 * We need this JSDoc comment for affecting ESDoc.
 * @ignore
 * @extends {Ignored}
 */
export class RaceSubscriber<T> extends OuterSubscriber<T, T> {
  private hasFirst: boolean = false;
  private observables: Observable<any>[] = [];
  private subscriptions: Subscription[] = [];

constructor(destination: Subscriber<T>) {
    super(destination);
  }

protected _next(observable: any): void {
    this.observables.push(observable);
  }

protected _complete() {
    const observables = this.observables;
    const len = observables.length;

if (len === 0) {
      this.destination.complete();
    } else {
      for (let i = 0; i < len && !this.hasFirst; i++) {
        let observable = observables[i];
        let subscription = subscribeToResult(this, observable, observable, i);

if (this.subscriptions) {
          this.subscriptions.push(subscription);
        }
        this.add(subscription);
      }
      this.observables = null;
    }
  }

notifyNext(outerValue: T, innerValue: T,
             outerIndex: number, innerIndex: number,
             innerSub: InnerSubscriber<T, T>): void {
    if (!this.hasFirst) {
      this.hasFirst = true;

for (let i = 0; i < this.subscriptions.length; i++) {
        if (i !== outerIndex) {
          let subscription = this.subscriptions[i];

subscription.unsubscribe();
          this.remove(subscription);
        }
      }

this.subscriptions = null;
    }

this.destination.next(innerValue);
  }
}