Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
audit.ts	4.21 KB	-rw-rw-r--	2022-08-30 11:49
auditTime.ts	2.34 KB	-rw-rw-r--	2022-08-30 11:49
buffer.ts	2.64 KB	-rw-rw-r--	2022-08-30 11:49
bufferCount.ts	4.36 KB	-rw-rw-r--	2022-08-30 11:49
bufferTime.ts	8.23 KB	-rw-rw-r--	2022-08-30 11:49
bufferToggle.ts	5.66 KB	-rw-rw-r--	2022-08-30 11:49
bufferWhen.ts	4.04 KB	-rw-rw-r--	2022-08-30 11:49
catchError.ts	3.75 KB	-rw-rw-r--	2022-08-30 11:49
combineAll.ts	349 B	-rw-rw-r--	2022-08-30 11:49
combineLatest.ts	7.61 KB	-rw-rw-r--	2022-08-30 11:49
concat.ts	3.73 KB	-rw-rw-r--	2022-08-30 11:49
concatAll.ts	1.99 KB	-rw-rw-r--	2022-08-30 11:49
concatMap.ts	3.5 KB	-rw-rw-r--	2022-08-30 11:49
concatMapTo.ts	3.29 KB	-rw-rw-r--	2022-08-30 11:49
count.ts	3.68 KB	-rw-rw-r--	2022-08-30 11:49
debounce.ts	4.74 KB	-rw-rw-r--	2022-08-30 11:49
debounceTime.ts	4.21 KB	-rw-rw-r--	2022-08-30 11:49
defaultIfEmpty.ts	2.63 KB	-rw-rw-r--	2022-08-30 11:49
delay.ts	4.9 KB	-rw-rw-r--	2022-08-30 11:49
delayWhen.ts	6.72 KB	-rw-rw-r--	2022-08-30 11:49
dematerialize.ts	2.52 KB	-rw-rw-r--	2022-08-30 11:49
distinct.ts	4.33 KB	-rw-rw-r--	2022-08-30 11:49
distinctUntilChanged.ts	3.77 KB	-rw-rw-r--	2022-08-30 11:49
distinctUntilKeyChanged.ts	2.56 KB	-rw-rw-r--	2022-08-30 11:49
elementAt.ts	3.2 KB	-rw-rw-r--	2022-08-30 11:49
every.ts	2.5 KB	-rw-rw-r--	2022-08-30 11:49
exhaust.ts	3.04 KB	-rw-rw-r--	2022-08-30 11:49
exhaustMap.ts	5.9 KB	-rw-rw-r--	2022-08-30 11:49
expand.ts	6.18 KB	-rw-rw-r--	2022-08-30 11:49
filter.ts	3.68 KB	-rw-rw-r--	2022-08-30 11:49
finalize.ts	1.31 KB	-rw-rw-r--	2022-08-30 11:49
find.ts	4 KB	-rw-rw-r--	2022-08-30 11:49
findIndex.ts	1.81 KB	-rw-rw-r--	2022-08-30 11:49
first.ts	6.55 KB	-rw-rw-r--	2022-08-30 11:49
groupBy.ts	9.53 KB	-rw-rw-r--	2022-08-30 11:49
ignoreElements.ts	1.16 KB	-rw-rw-r--	2022-08-30 11:49
isEmpty.ts	1016 B	-rw-rw-r--	2022-08-30 11:49
last.ts	5.2 KB	-rw-rw-r--	2022-08-30 11:49
map.ts	2.99 KB	-rw-rw-r--	2022-08-30 11:49
mapTo.ts	1.85 KB	-rw-rw-r--	2022-08-30 11:49
materialize.ts	3.19 KB	-rw-rw-r--	2022-08-30 11:49
max.ts	1.48 KB	-rw-rw-r--	2022-08-30 11:49
merge.ts	4.8 KB	-rw-rw-r--	2022-08-30 11:49
mergeAll.ts	2.32 KB	-rw-rw-r--	2022-08-30 11:49
mergeMap.ts	6.6 KB	-rw-rw-r--	2022-08-30 11:49
mergeMapTo.ts	6.55 KB	-rw-rw-r--	2022-08-30 11:49
mergeScan.ts	4.32 KB	-rw-rw-r--	2022-08-30 11:49
min.ts	1.49 KB	-rw-rw-r--	2022-08-30 11:49
multicast.ts	3.28 KB	-rw-rw-r--	2022-08-30 11:49
observeOn.ts	4.98 KB	-rw-rw-r--	2022-08-30 11:49
onErrorResumeNext.ts	7.49 KB	-rw-rw-r--	2022-08-30 11:49
pairwise.ts	2.26 KB	-rw-rw-r--	2022-08-30 11:49
partition.ts	2.56 KB	-rw-rw-r--	2022-08-30 11:49
pluck.ts	1.76 KB	-rw-rw-r--	2022-08-30 11:49
publish.ts	1.56 KB	-rw-rw-r--	2022-08-30 11:49
publishBehavior.ts	594 B	-rw-rw-r--	2022-08-30 11:49
publishLast.ts	429 B	-rw-rw-r--	2022-08-30 11:49
publishReplay.ts	1.63 KB	-rw-rw-r--	2022-08-30 11:49
race.ts	1.55 KB	-rw-rw-r--	2022-08-30 11:49
reduce.ts	3.64 KB	-rw-rw-r--	2022-08-30 11:49
refCount.ts	3.01 KB	-rw-rw-r--	2022-08-30 11:49
repeat.ts	1.96 KB	-rw-rw-r--	2022-08-30 11:49
repeatWhen.ts	4.1 KB	-rw-rw-r--	2022-08-30 11:49
retry.ts	2.15 KB	-rw-rw-r--	2022-08-30 11:49
retryWhen.ts	3.8 KB	-rw-rw-r--	2022-08-30 11:49
sample.ts	2.93 KB	-rw-rw-r--	2022-08-30 11:49
sampleTime.ts	3.19 KB	-rw-rw-r--	2022-08-30 11:49
scan.ts	4.08 KB	-rw-rw-r--	2022-08-30 11:49
sequenceEqual.ts	4.96 KB	-rw-rw-r--	2022-08-30 11:49
share.ts	1.04 KB	-rw-rw-r--	2022-08-30 11:49
shareReplay.ts	1.52 KB	-rw-rw-r--	2022-08-30 11:49
single.ts	3.01 KB	-rw-rw-r--	2022-08-30 11:49
skip.ts	1.34 KB	-rw-rw-r--	2022-08-30 11:49
skipLast.ts	2.8 KB	-rw-rw-r--	2022-08-30 11:49
skipUntil.ts	2.27 KB	-rw-rw-r--	2022-08-30 11:49
skipWhile.ts	2.01 KB	-rw-rw-r--	2022-08-30 11:49
startWith.ts	2.43 KB	-rw-rw-r--	2022-08-30 11:49
subscribeOn.ts	1.32 KB	-rw-rw-r--	2022-08-30 11:49
switchAll.ts	282 B	-rw-rw-r--	2022-08-30 11:49
switchMap.ts	6.05 KB	-rw-rw-r--	2022-08-30 11:49
switchMapTo.ts	5.5 KB	-rw-rw-r--	2022-08-30 11:49
take.ts	2.69 KB	-rw-rw-r--	2022-08-30 11:49
takeLast.ts	3.46 KB	-rw-rw-r--	2022-08-30 11:49
takeUntil.ts	2.65 KB	-rw-rw-r--	2022-08-30 11:49
takeWhile.ts	3.13 KB	-rw-rw-r--	2022-08-30 11:49
tap.ts	4.51 KB	-rw-rw-r--	2022-08-30 11:49
throttle.ts	5.3 KB	-rw-rw-r--	2022-08-30 11:49
throttleTime.ts	4.31 KB	-rw-rw-r--	2022-08-30 11:49
timeInterval.ts	1.33 KB	-rw-rw-r--	2022-08-30 11:49
timeout.ts	6.12 KB	-rw-rw-r--	2022-08-30 11:49
timeoutWith.ts	6.24 KB	-rw-rw-r--	2022-08-30 11:49
timestamp.ts	659 B	-rw-rw-r--	2022-08-30 11:49
toArray.ts	352 B	-rw-rw-r--	2022-08-30 11:49
window.ts	3.81 KB	-rw-rw-r--	2022-08-30 11:49
windowCount.ts	4.63 KB	-rw-rw-r--	2022-08-30 11:49
windowTime.ts	9.48 KB	-rw-rw-r--	2022-08-30 11:49
windowToggle.ts	6.24 KB	-rw-rw-r--	2022-08-30 11:49
windowWhen.ts	4.58 KB	-rw-rw-r--	2022-08-30 11:49
withLatestFrom.ts	6.84 KB	-rw-rw-r--	2022-08-30 11:49
zip.ts	12.74 KB	-rw-rw-r--	2022-08-30 11:49
zipAll.ts	304 B	-rw-rw-r--	2022-08-30 11:49

Rename

import { IScheduler } from '../Scheduler';
import { Action } from '../scheduler/Action';
import { Subject } from '../Subject';
import { Operator } from '../Operator';
import { async } from '../scheduler/async';
import { Subscriber } from '../Subscriber';
import { Observable } from '../Observable';
import { Subscription } from '../Subscription';
import { isNumeric } from '../util/isNumeric';
import { isScheduler } from '../util/isScheduler';
import { OperatorFunction } from '../interfaces';

/**
 * Branch out the source Observable values as a nested Observable periodically
 * in time.
 *
 * <span class="informal">It's like {@link bufferTime}, but emits a nested
 * Observable instead of an array.</span>
 *
 * <img src="./img/windowTime.png" width="100%">
 *
 * Returns an Observable that emits windows of items it collects from the source
 * Observable. The output Observable starts a new window periodically, as
 * determined by the `windowCreationInterval` argument. It emits each window
 * after a fixed timespan, specified by the `windowTimeSpan` argument. When the
 * source Observable completes or encounters an error, the output Observable
 * emits the current window and propagates the notification from the source
 * Observable. If `windowCreationInterval` is not provided, the output
 * Observable starts a new window when the previous window of duration
 * `windowTimeSpan` completes. If `maxWindowCount` is provided, each window
 * will emit at most fixed number of values. Window will complete immediately
 * after emitting last value and next one still will open as specified by
 * `windowTimeSpan` and `windowCreationInterval` arguments.
 *
 * @example <caption>In every window of 1 second each, emit at most 2 click events</caption>
 * var clicks = Rx.Observable.fromEvent(document, 'click');
 * var result = clicks.windowTime(1000)
 *   .map(win => win.take(2)) // each window has at most 2 emissions
 *   .mergeAll(); // flatten the Observable-of-Observables
 * result.subscribe(x => console.log(x));
 *
 * @example <caption>Every 5 seconds start a window 1 second long, and emit at most 2 click events per window</caption>
 * var clicks = Rx.Observable.fromEvent(document, 'click');
 * var result = clicks.windowTime(1000, 5000)
 *   .map(win => win.take(2)) // each window has at most 2 emissions
 *   .mergeAll(); // flatten the Observable-of-Observables
 * result.subscribe(x => console.log(x));
 *
 * @example <caption>Same as example above but with maxWindowCount instead of take</caption>
 * var clicks = Rx.Observable.fromEvent(document, 'click');
 * var result = clicks.windowTime(1000, 5000, 2) // each window has still at most 2 emissions
 *   .mergeAll(); // flatten the Observable-of-Observables
 * result.subscribe(x => console.log(x));

* @see {@link window}
 * @see {@link windowCount}
 * @see {@link windowToggle}
 * @see {@link windowWhen}
 * @see {@link bufferTime}
 *
 * @param {number} windowTimeSpan The amount of time to fill each window.
 * @param {number} [windowCreationInterval] The interval at which to start new
 * windows.
 * @param {number} [maxWindowSize=Number.POSITIVE_INFINITY] Max number of
 * values each window can emit before completion.
 * @param {Scheduler} [scheduler=async] The scheduler on which to schedule the
 * intervals that determine window boundaries.
 * @return {Observable<Observable<T>>} An observable of windows, which in turn
 * are Observables.
 * @method windowTime
 * @owner Observable
 */
export function windowTime<T>(windowTimeSpan: number,
                              scheduler?: IScheduler): OperatorFunction<T, Observable<T>>;
export function windowTime<T>(windowTimeSpan: number,
                              windowCreationInterval: number,
                              scheduler?: IScheduler): OperatorFunction<T, Observable<T>>;
export function windowTime<T>(windowTimeSpan: number,
                              windowCreationInterval: number,
                              maxWindowSize: number,
                              scheduler?: IScheduler): OperatorFunction<T, Observable<T>>;

export function windowTime<T>(windowTimeSpan: number): OperatorFunction<T, Observable<T>> {
  let scheduler: IScheduler = async;
  let windowCreationInterval: number = null;
  let maxWindowSize: number = Number.POSITIVE_INFINITY;

if (isScheduler(arguments[3])) {
    scheduler = arguments[3];
  }

if (isScheduler(arguments[2])) {
    scheduler = arguments[2];
  } else if (isNumeric(arguments[2])) {
    maxWindowSize = arguments[2];
  }

if (isScheduler(arguments[1])) {
    scheduler = arguments[1];
  } else if (isNumeric(arguments[1])) {
    windowCreationInterval = arguments[1];
  }

return function windowTimeOperatorFunction(source: Observable<T>) {
    return source.lift(new WindowTimeOperator<T>(windowTimeSpan, windowCreationInterval, maxWindowSize, scheduler));
  };
}

class WindowTimeOperator<T> implements Operator<T, Observable<T>> {

constructor(private windowTimeSpan: number,
              private windowCreationInterval: number | null,
              private maxWindowSize: number,
              private scheduler: IScheduler) {
  }

call(subscriber: Subscriber<Observable<T>>, source: any): any {
    return source.subscribe(new WindowTimeSubscriber(
      subscriber, this.windowTimeSpan, this.windowCreationInterval, this.maxWindowSize, this.scheduler
    ));
  }
}

interface CreationState<T> {
  windowTimeSpan: number;
  windowCreationInterval: number;
  subscriber: WindowTimeSubscriber<T>;
  scheduler: IScheduler;
}

interface TimeSpanOnlyState<T> {
    window: CountedSubject<T>;
    windowTimeSpan: number;
    subscriber: WindowTimeSubscriber<T>;
  }

interface CloseWindowContext<T> {
  action: Action<CreationState<T>>;
  subscription: Subscription;
}

interface CloseState<T> {
  subscriber: WindowTimeSubscriber<T>;
  window: CountedSubject<T>;
  context: CloseWindowContext<T>;
}

class CountedSubject<T> extends Subject<T> {
  private _numberOfNextedValues: number = 0;

next(value?: T): void {
    this._numberOfNextedValues++;
    super.next(value);
  }

get numberOfNextedValues(): number {
    return this._numberOfNextedValues;
  }
}

/**
 * We need this JSDoc comment for affecting ESDoc.
 * @ignore
 * @extends {Ignored}
 */
class WindowTimeSubscriber<T> extends Subscriber<T> {
  private windows: CountedSubject<T>[] = [];

constructor(protected destination: Subscriber<Observable<T>>,
              private windowTimeSpan: number,
              private windowCreationInterval: number | null,
              private maxWindowSize: number,
              private scheduler: IScheduler) {
    super(destination);

protected _next(value: T): void {
    const windows = this.windows;
    const len = windows.length;
    for (let i = 0; i < len; i++) {
      const window = windows[i];
      if (!window.closed) {
        window.next(value);
        if (window.numberOfNextedValues >= this.maxWindowSize) {
          this.closeWindow(window);
        }
      }
    }
  }

protected _error(err: any): void {
    const windows = this.windows;
    while (windows.length > 0) {
      windows.shift().error(err);
    }
    this.destination.error(err);
  }

protected _complete(): void {
    const windows = this.windows;
    while (windows.length > 0) {
      const window = windows.shift();
      if (!window.closed) {
        window.complete();
      }
    }
    this.destination.complete();
  }

public openWindow(): CountedSubject<T> {
    const window = new CountedSubject<T>();
    this.windows.push(window);
    const destination = this.destination;
    destination.next(window);
    return window;
  }

public closeWindow(window: CountedSubject<T>): void {
    window.complete();
    const windows = this.windows;
    windows.splice(windows.indexOf(window), 1);
  }
}

function dispatchWindowTimeSpanOnly<T>(this: Action<TimeSpanOnlyState<T>>, state: TimeSpanOnlyState<T>): void {
  const { subscriber, windowTimeSpan, window } = state;
  if (window) {
    subscriber.closeWindow(window);
  }
  state.window = subscriber.openWindow();
  this.schedule(state, windowTimeSpan);
}

function dispatchWindowCreation<T>(this: Action<CreationState<T>>, state: CreationState<T>): void {
  const { windowTimeSpan, subscriber, scheduler, windowCreationInterval } = state;
  const window = subscriber.openWindow();
  const action = this;
  let context: CloseWindowContext<T> = { action, subscription: <any>null };
  const timeSpanState: CloseState<T> = { subscriber, window, context };
  context.subscription = scheduler.schedule(dispatchWindowClose, windowTimeSpan, timeSpanState);
  action.add(context.subscription);
  action.schedule(state, windowCreationInterval);
}

function dispatchWindowClose<T>(state: CloseState<T>): void {
  const { subscriber, window, context } = state;
  if (context && context.action && context.subscription) {
    context.action.remove(context.subscription);
  }
  subscriber.closeWindow(window);
}