Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
add	[ 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
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.js	1.82 KB	-rw-rw-r--	2022-08-30 11:49
AsyncSubject.js.map	1.32 KB	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.js	1.71 KB	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.js.map	1.04 KB	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.js	1.3 KB	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.js.map	806 B	-rw-rw-r--	2022-08-30 11:49
LICENSE.txt	10.8 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	2.3 KB	-rw-rw-r--	2022-08-30 11:49
Observable.js	12.9 KB	-rw-rw-r--	2022-08-30 11:49
Observable.js.map	4.16 KB	-rw-rw-r--	2022-08-30 11:49
Observer.js	227 B	-rw-rw-r--	2022-08-30 11:49
Observer.js.map	271 B	-rw-rw-r--	2022-08-30 11:49
Operator.js	37 B	-rw-rw-r--	2022-08-30 11:49
Operator.js.map	108 B	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.js	1.12 KB	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.js.map	570 B	-rw-rw-r--	2022-08-30 11:49
README.md	7.27 KB	-rw-rw-r--	2022-08-30 11:49
ReplaySubject.js	3.93 KB	-rw-rw-r--	2022-08-30 11:49
ReplaySubject.js.map	3.1 KB	-rw-rw-r--	2022-08-30 11:49
Rx.js	8.07 KB	-rw-rw-r--	2022-08-30 11:49
Rx.js.map	2.98 KB	-rw-rw-r--	2022-08-30 11:49
Scheduler.js	1.87 KB	-rw-rw-r--	2022-08-30 11:49
Scheduler.js.map	631 B	-rw-rw-r--	2022-08-30 11:49
Subject.js	5.48 KB	-rw-rw-r--	2022-08-30 11:49
Subject.js.map	4.4 KB	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.js	1.4 KB	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.js.map	956 B	-rw-rw-r--	2022-08-30 11:49
Subscriber.js	10.12 KB	-rw-rw-r--	2022-08-30 11:49
Subscriber.js.map	6.58 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.js	7.9 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.js.map	4.83 KB	-rw-rw-r--	2022-08-30 11:49
interfaces.js	39 B	-rw-rw-r--	2022-08-30 11:49
interfaces.js.map	112 B	-rw-rw-r--	2022-08-30 11:49
operators.js	5.35 KB	-rw-rw-r--	2022-08-30 11:49
operators.js.map	3.4 KB	-rw-rw-r--	2022-08-30 11:49
path-mapping.js	33.37 KB	-rw-rw-r--	2022-08-30 11:49

Rename

/** PURE_IMPORTS_START ._Observable,._Subscriber,._Subscription,._util_ObjectUnsubscribedError,._SubjectSubscription,._symbol_rxSubscriber PURE_IMPORTS_END */
var __extends = (this && this.__extends) || function (d, b) {
    for (var p in b)
        if (b.hasOwnProperty(p))
            d[p] = b[p];
    function __() { this.constructor = d; }
    d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
};
import { Observable } from './Observable';
import { Subscriber } from './Subscriber';
import { Subscription } from './Subscription';
import { ObjectUnsubscribedError } from './util/ObjectUnsubscribedError';
import { SubjectSubscription } from './SubjectSubscription';
import { rxSubscriber as rxSubscriberSymbol } from './symbol/rxSubscriber';
/**
 * @class SubjectSubscriber<T>
 */
export var SubjectSubscriber = /*@__PURE__*/ (/*@__PURE__*/ function (_super) {
    __extends(SubjectSubscriber, _super);
    function SubjectSubscriber(destination) {
        _super.call(this, destination);
        this.destination = destination;
    }
    return SubjectSubscriber;
}(Subscriber));
/**
 * @class Subject<T>
 */
export var Subject = /*@__PURE__*/ (/*@__PURE__*/ function (_super) {
    __extends(Subject, _super);
    function Subject() {
        _super.call(this);
        this.observers = [];
        this.closed = false;
        this.isStopped = false;
        this.hasError = false;
        this.thrownError = null;
    }
    Subject.prototype[rxSubscriberSymbol] = function () {
        return new SubjectSubscriber(this);
    };
    Subject.prototype.lift = function (operator) {
        var subject = new AnonymousSubject(this, this);
        subject.operator = operator;
        return subject;
    };
    Subject.prototype.next = function (value) {
        if (this.closed) {
            throw new ObjectUnsubscribedError();
        }
        if (!this.isStopped) {
            var observers = this.observers;
            var len = observers.length;
            var copy = observers.slice();
            for (var i = 0; i < len; i++) {
                copy[i].next(value);
            }
        }
    };
    Subject.prototype.error = function (err) {
        if (this.closed) {
            throw new ObjectUnsubscribedError();
        }
        this.hasError = true;
        this.thrownError = err;
        this.isStopped = true;
        var observers = this.observers;
        var len = observers.length;
        var copy = observers.slice();
        for (var i = 0; i < len; i++) {
            copy[i].error(err);
        }
        this.observers.length = 0;
    };
    Subject.prototype.complete = function () {
        if (this.closed) {
            throw new ObjectUnsubscribedError();
        }
        this.isStopped = true;
        var observers = this.observers;
        var len = observers.length;
        var copy = observers.slice();
        for (var i = 0; i < len; i++) {
            copy[i].complete();
        }
        this.observers.length = 0;
    };
    Subject.prototype.unsubscribe = function () {
        this.isStopped = true;
        this.closed = true;
        this.observers = null;
    };
    Subject.prototype._trySubscribe = function (subscriber) {
        if (this.closed) {
            throw new ObjectUnsubscribedError();
        }
        else {
            return _super.prototype._trySubscribe.call(this, subscriber);
        }
    };
    /** @deprecated internal use only */ Subject.prototype._subscribe = function (subscriber) {
        if (this.closed) {
            throw new ObjectUnsubscribedError();
        }
        else if (this.hasError) {
            subscriber.error(this.thrownError);
            return Subscription.EMPTY;
        }
        else if (this.isStopped) {
            subscriber.complete();
            return Subscription.EMPTY;
        }
        else {
            this.observers.push(subscriber);
            return new SubjectSubscription(this, subscriber);
        }
    };
    Subject.prototype.asObservable = function () {
        var observable = new Observable();
        observable.source = this;
        return observable;
    };
    Subject.create = function (destination, source) {
        return new AnonymousSubject(destination, source);
    };
    return Subject;
}(Observable));
/**
 * @class AnonymousSubject<T>
 */
export var AnonymousSubject = /*@__PURE__*/ (/*@__PURE__*/ function (_super) {
    __extends(AnonymousSubject, _super);
    function AnonymousSubject(destination, source) {
        _super.call(this);
        this.destination = destination;
        this.source = source;
    }
    AnonymousSubject.prototype.next = function (value) {
        var destination = this.destination;
        if (destination && destination.next) {
            destination.next(value);
        }
    };
    AnonymousSubject.prototype.error = function (err) {
        var destination = this.destination;
        if (destination && destination.error) {
            this.destination.error(err);
        }
    };
    AnonymousSubject.prototype.complete = function () {
        var destination = this.destination;
        if (destination && destination.complete) {
            this.destination.complete();
        }
    };
    /** @deprecated internal use only */ AnonymousSubject.prototype._subscribe = function (subscriber) {
        var source = this.source;
        if (source) {
            return this.source.subscribe(subscriber);
        }
        else {
            return Subscription.EMPTY;
        }
    };
    return AnonymousSubject;
}(Subject));
//# sourceMappingURL=Subject.js.map