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 : 3.144.132.48
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.ts	1.04 KB	-rw-rw-r--	2022-08-30 11:49
BUILD.bazel	650 B	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.ts	962 B	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.ts	742 B	-rw-rw-r--	2022-08-30 11:49
LICENSE.txt	10.8 KB	-rw-rw-r--	2022-08-30 11:49
MiscJSDoc.ts	15.3 KB	-rw-rw-r--	2022-08-30 11:49
Notification.ts	4.32 KB	-rw-rw-r--	2022-08-30 11:49
Observable.ts	14.9 KB	-rw-rw-r--	2022-08-30 11:49
Observer.ts	828 B	-rw-rw-r--	2022-08-30 11:49
Operator.ts	191 B	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.ts	646 B	-rw-rw-r--	2022-08-30 11:49
README.md	7.27 KB	-rw-rw-r--	2022-08-30 11:49
ReplaySubject.ts	2.94 KB	-rw-rw-r--	2022-08-30 11:49
Rx.global.js	137 B	-rw-rw-r--	2022-08-30 11:49
Rx.ts	8.16 KB	-rw-rw-r--	2022-08-30 11:49
Scheduler.ts	2.29 KB	-rw-rw-r--	2022-08-30 11:49
Subject.ts	4.04 KB	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.ts	849 B	-rw-rw-r--	2022-08-30 11:49
Subscriber.ts	8.63 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.ts	7.08 KB	-rw-rw-r--	2022-08-30 11:49
WORKSPACE	25 B	-rw-rw-r--	2022-08-30 11:49
interfaces.ts	294 B	-rw-rw-r--	2022-08-30 11:49
operators.ts	5.27 KB	-rw-rw-r--	2022-08-30 11:49
tsconfig.json	640 B	-rw-rw-r--	2022-08-30 11:49

Rename

import { Subject } from './Subject';
import { Subscriber } from './Subscriber';
import { Subscription } from './Subscription';

/**
 * @class AsyncSubject<T>
 */
export class AsyncSubject<T> extends Subject<T> {
  private value: T = null;
  private hasNext: boolean = false;
  private hasCompleted: boolean = false;

/** @deprecated internal use only */ _subscribe(subscriber: Subscriber<any>): Subscription {
    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: T): void {
    if (!this.hasCompleted) {
      this.value = value;
      this.hasNext = true;
    }
  }

error(error: any): void {
    if (!this.hasCompleted) {
      super.error(error);
    }
  }

complete(): void {
    this.hasCompleted = true;
    if (this.hasNext) {
      super.next(this.value);
    }
    super.complete();
  }
}