Gecko [ unitednationsplay.com ]

Linux unitednationsplay.com 3.10.0-1160.45.1.el7.x86_64 #1 SMP Wed Oct 13 17:20:51 UTC 2021 x86_64
nginx/1.20.1
Server IP : 188.130.139.92 & Your IP : 18.227.140.134
Domains : Cant Read [ /etc/named.conf ]
User : web

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.14 KB	-rw-rw-r--	2022-08-30 11:49
AsyncSubject.js.map	1.26 KB	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.js	950 B	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.js.map	992 B	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.js	745 B	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.js.map	748 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.32 KB	-rw-rw-r--	2022-08-30 11:49
Notification.js.map	2.25 KB	-rw-rw-r--	2022-08-30 11:49
Observable.js	12.15 KB	-rw-rw-r--	2022-08-30 11:49
Observable.js.map	4 KB	-rw-rw-r--	2022-08-30 11:49
Observer.js	151 B	-rw-rw-r--	2022-08-30 11:49
Observer.js.map	270 B	-rw-rw-r--	2022-08-30 11:49
Operator.js	36 B	-rw-rw-r--	2022-08-30 11:49
Operator.js.map	108 B	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.js	508 B	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.js.map	491 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.01 KB	-rw-rw-r--	2022-08-30 11:49
ReplaySubject.js.map	2.97 KB	-rw-rw-r--	2022-08-30 11:49
Rx.js	7.81 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.63 KB	-rw-rw-r--	2022-08-30 11:49
Scheduler.js.map	549 B	-rw-rw-r--	2022-08-30 11:49
Subject.js	4.19 KB	-rw-rw-r--	2022-08-30 11:49
Subject.js.map	4.38 KB	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.js	915 B	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.js.map	913 B	-rw-rw-r--	2022-08-30 11:49
Subscriber.js	8.83 KB	-rw-rw-r--	2022-08-30 11:49
Subscriber.js.map	6.48 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.js	7.42 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.js.map	4.78 KB	-rw-rw-r--	2022-08-30 11:49
interfaces.js	38 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.3 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

import { Subject } from './Subject';
import { Subscription } from './Subscription';
/**
 * @class AsyncSubject<T>
 */
export class AsyncSubject extends Subject {
    constructor() {
        super(...arguments);
        this.value = null;
        this.hasNext = false;
        this.hasCompleted = false;
    }
    /** @deprecated internal use only */ _subscribe(subscriber) {
        if (this.hasError) {
            subscriber.error(this.thrownError);
            return Subscription.EMPTY;
        }
        else if (this.hasCompleted && this.hasNext) {
            subscriber.next(this.value);
            subscriber.complete();
            return Subscription.EMPTY;
        }
        return super._subscribe(subscriber);
    }
    next(value) {
        if (!this.hasCompleted) {
            this.value = value;
            this.hasNext = true;
        }
    }
    error(error) {
        if (!this.hasCompleted) {
            super.error(error);
        }
    }
    complete() {
        this.hasCompleted = true;
        if (this.hasNext) {
            super.next(this.value);
        }
        super.complete();
    }
}
//# sourceMappingURL=AsyncSubject.js.map