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, SubscribableOrPromise } from '../Observable';
import { Subscriber } from '../Subscriber';
import { Subscription } from '../Subscription';

import { subscribeToResult } from '../util/subscribeToResult';
import { OuterSubscriber } from '../OuterSubscriber';
/**
 * We need this JSDoc comment for affecting ESDoc.
 * @extends {Ignored}
 * @hide true
 */
export class DeferObservable<T> extends Observable<T> {

/**
   * Creates an Observable that, on subscribe, calls an Observable factory to
   * make an Observable for each new Observer.
   *
   * <span class="informal">Creates the Observable lazily, that is, only when it
   * is subscribed.
   * </span>
   *
   * <img src="./img/defer.png" width="100%">
   *
   * `defer` allows you to create the Observable only when the Observer
   * subscribes, and create a fresh Observable for each Observer. It waits until
   * an Observer subscribes to it, and then it generates an Observable,
   * typically with an Observable factory function. It does this afresh for each
   * subscriber, so although each subscriber may think it is subscribing to the
   * same Observable, in fact each subscriber gets its own individual
   * Observable.
   *
   * @example <caption>Subscribe to either an Observable of clicks or an Observable of interval, at random</caption>
   * var clicksOrInterval = Rx.Observable.defer(function () {
   *   if (Math.random() > 0.5) {
   *     return Rx.Observable.fromEvent(document, 'click');
   *   } else {
   *     return Rx.Observable.interval(1000);
   *   }
   * });
   * clicksOrInterval.subscribe(x => console.log(x));
   *
   * // Results in the following behavior:
   * // If the result of Math.random() is greater than 0.5 it will listen
   * // for clicks anywhere on the "document"; when document is clicked it
   * // will log a MouseEvent object to the console. If the result is less
   * // than 0.5 it will emit ascending numbers, one every second(1000ms).
   *
   * @see {@link create}
   *
   * @param {function(): SubscribableOrPromise} observableFactory The Observable
   * factory function to invoke for each Observer that subscribes to the output
   * Observable. May also return a Promise, which will be converted on the fly
   * to an Observable.
   * @return {Observable} An Observable whose Observers' subscriptions trigger
   * an invocation of the given Observable factory function.
   * @static true
   * @name defer
   * @owner Observable
   */
  static create<T>(observableFactory: () => SubscribableOrPromise<T> | void): Observable<T> {
    return new DeferObservable(observableFactory);
  }

constructor(private observableFactory: () => SubscribableOrPromise<T> | void) {
    super();
  }

/** @deprecated internal use only */ _subscribe(subscriber: Subscriber<T>): Subscription {
    return new DeferSubscriber(subscriber, this.observableFactory);
  }
}

class DeferSubscriber<T> extends OuterSubscriber<T, T> {
  constructor(destination: Subscriber<T>,
              private factory: () => SubscribableOrPromise<T> | void) {
    super(destination);
    this.tryDefer();
  }

private tryDefer(): void {
    try {
      this._callFactory();
    } catch (err) {
      this._error(err);
    }
  }

private _callFactory(): void {
    const result = this.factory();
    if (result) {
      this.add(subscribeToResult(this, result));
    }
  }
}