Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
_esm2015	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
_esm5	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
add	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
bundles	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
observable	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
operator	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
operators	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
scheduler	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
src	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
symbol	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
testing	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
util	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
AsyncSubject.d.ts	460 B	-rw-rw-r--	2022-08-30 11:49
AsyncSubject.js	1.79 KB	-rw-rw-r--	2022-08-30 11:49
AsyncSubject.js.map	2.45 KB	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.d.ts	437 B	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.js	1.66 KB	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.js.map	2.06 KB	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.d.ts	537 B	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.js	1.26 KB	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.js.map	1.58 KB	-rw-rw-r--	2022-08-30 11:49
LICENSE.txt	10.8 KB	-rw-rw-r--	2022-08-30 11:49
Notification.d.ts	3.07 KB	-rw-rw-r--	2022-08-30 11:49
Notification.js	4.65 KB	-rw-rw-r--	2022-08-30 11:49
Notification.js.map	6.81 KB	-rw-rw-r--	2022-08-30 11:49
Observable.d.ts	5 KB	-rw-rw-r--	2022-08-30 11:49
Observable.js	12.89 KB	-rw-rw-r--	2022-08-30 11:49
Observable.js.map	19.46 KB	-rw-rw-r--	2022-08-30 11:49
Observer.d.ts	737 B	-rw-rw-r--	2022-08-30 11:49
Observer.js	193 B	-rw-rw-r--	2022-08-30 11:49
Observer.js.map	1.12 KB	-rw-rw-r--	2022-08-30 11:49
Operator.d.ts	192 B	-rw-rw-r--	2022-08-30 11:49
Operator.js	50 B	-rw-rw-r--	2022-08-30 11:49
Operator.js.map	327 B	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.d.ts	509 B	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.js	1.08 KB	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.js.map	1.25 KB	-rw-rw-r--	2022-08-30 11:49
README.md	7.27 KB	-rw-rw-r--	2022-08-30 11:49
ReplaySubject.d.ts	625 B	-rw-rw-r--	2022-08-30 11:49
ReplaySubject.js	3.81 KB	-rw-rw-r--	2022-08-30 11:49
ReplaySubject.js.map	6.16 KB	-rw-rw-r--	2022-08-30 11:49
Rx.d.ts	7.59 KB	-rw-rw-r--	2022-08-30 11:49
Rx.js	9.56 KB	-rw-rw-r--	2022-08-30 11:49
Rx.js.map	13.4 KB	-rw-rw-r--	2022-08-30 11:49
Scheduler.d.ts	2.18 KB	-rw-rw-r--	2022-08-30 11:49
Scheduler.js	1.84 KB	-rw-rw-r--	2022-08-30 11:49
Scheduler.js.map	3.01 KB	-rw-rw-r--	2022-08-30 11:49
Subject.d.ts	1.41 KB	-rw-rw-r--	2022-08-30 11:49
Subject.js	5.55 KB	-rw-rw-r--	2022-08-30 11:49
Subject.js.map	8.67 KB	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.d.ts	447 B	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.js	1.37 KB	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.js.map	1.85 KB	-rw-rw-r--	2022-08-30 11:49
Subscriber.d.ts	2.97 KB	-rw-rw-r--	2022-08-30 11:49
Subscriber.js	10.02 KB	-rw-rw-r--	2022-08-30 11:49
Subscriber.js.map	15.51 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.d.ts	2.74 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.js	7.99 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.js.map	12.17 KB	-rw-rw-r--	2022-08-30 11:49
interfaces.d.ts	322 B	-rw-rw-r--	2022-08-30 11:49
interfaces.js	52 B	-rw-rw-r--	2022-08-30 11:49
interfaces.js.map	437 B	-rw-rw-r--	2022-08-30 11:49
operators.d.ts	5.21 KB	-rw-rw-r--	2022-08-30 11:49
operators.js	9.52 KB	-rw-rw-r--	2022-08-30 11:49
operators.js.map	9.28 KB	-rw-rw-r--	2022-08-30 11:49
package.json	5.16 KB	-rw-rw-r--	2022-08-30 11:49

Rename

"use strict";
var Observable_1 = require('./Observable');
/**
 * Represents a push-based event or value that an {@link Observable} can emit.
 * This class is particularly useful for operators that manage notifications,
 * like {@link materialize}, {@link dematerialize}, {@link observeOn}, and
 * others. Besides wrapping the actual delivered value, it also annotates it
 * with metadata of, for instance, what type of push message it is (`next`,
 * `error`, or `complete`).
 *
 * @see {@link materialize}
 * @see {@link dematerialize}
 * @see {@link observeOn}
 *
 * @class Notification<T>
 */
var Notification = (function () {
    function Notification(kind, value, error) {
        this.kind = kind;
        this.value = value;
        this.error = error;
        this.hasValue = kind === 'N';
    }
    /**
     * Delivers to the given `observer` the value wrapped by this Notification.
     * @param {Observer} observer
     * @return
     */
    Notification.prototype.observe = function (observer) {
        switch (this.kind) {
            case 'N':
                return observer.next && observer.next(this.value);
            case 'E':
                return observer.error && observer.error(this.error);
            case 'C':
                return observer.complete && observer.complete();
        }
    };
    /**
     * Given some {@link Observer} callbacks, deliver the value represented by the
     * current Notification to the correctly corresponding callback.
     * @param {function(value: T): void} next An Observer `next` callback.
     * @param {function(err: any): void} [error] An Observer `error` callback.
     * @param {function(): void} [complete] An Observer `complete` callback.
     * @return {any}
     */
    Notification.prototype.do = function (next, error, complete) {
        var kind = this.kind;
        switch (kind) {
            case 'N':
                return next && next(this.value);
            case 'E':
                return error && error(this.error);
            case 'C':
                return complete && complete();
        }
    };
    /**
     * Takes an Observer or its individual callback functions, and calls `observe`
     * or `do` methods accordingly.
     * @param {Observer|function(value: T): void} nextOrObserver An Observer or
     * the `next` callback.
     * @param {function(err: any): void} [error] An Observer `error` callback.
     * @param {function(): void} [complete] An Observer `complete` callback.
     * @return {any}
     */
    Notification.prototype.accept = function (nextOrObserver, error, complete) {
        if (nextOrObserver && typeof nextOrObserver.next === 'function') {
            return this.observe(nextOrObserver);
        }
        else {
            return this.do(nextOrObserver, error, complete);
        }
    };
    /**
     * Returns a simple Observable that just delivers the notification represented
     * by this Notification instance.
     * @return {any}
     */
    Notification.prototype.toObservable = function () {
        var kind = this.kind;
        switch (kind) {
            case 'N':
                return Observable_1.Observable.of(this.value);
            case 'E':
                return Observable_1.Observable.throw(this.error);
            case 'C':
                return Observable_1.Observable.empty();
        }
        throw new Error('unexpected notification kind value');
    };
    /**
     * A shortcut to create a Notification instance of the type `next` from a
     * given value.
     * @param {T} value The `next` value.
     * @return {Notification<T>} The "next" Notification representing the
     * argument.
     */
    Notification.createNext = function (value) {
        if (typeof value !== 'undefined') {
            return new Notification('N', value);
        }
        return Notification.undefinedValueNotification;
    };
    /**
     * A shortcut to create a Notification instance of the type `error` from a
     * given error.
     * @param {any} [err] The `error` error.
     * @return {Notification<T>} The "error" Notification representing the
     * argument.
     */
    Notification.createError = function (err) {
        return new Notification('E', undefined, err);
    };
    /**
     * A shortcut to create a Notification instance of the type `complete`.
     * @return {Notification<any>} The valueless "complete" Notification.
     */
    Notification.createComplete = function () {
        return Notification.completeNotification;
    };
    Notification.completeNotification = new Notification('C');
    Notification.undefinedValueNotification = new Notification('N', undefined);
    return Notification;
}());
exports.Notification = Notification;
//# sourceMappingURL=Notification.js.map