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.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 { Operator } from './Operator';
import { Observer } from './Observer';
import { Observable } from './Observable';
import { Subscriber } from './Subscriber';
import { ISubscription, Subscription, TeardownLogic } from './Subscription';
import { ObjectUnsubscribedError } from './util/ObjectUnsubscribedError';
import { SubjectSubscription } from './SubjectSubscription';
import { rxSubscriber as rxSubscriberSymbol } from './symbol/rxSubscriber';

/**
 * @class SubjectSubscriber<T>
 */
export class SubjectSubscriber<T> extends Subscriber<T> {
  constructor(protected destination: Subject<T>) {
    super(destination);
  }
}

/**
 * @class Subject<T>
 */
export class Subject<T> extends Observable<T> implements ISubscription {

[rxSubscriberSymbol]() {
    return new SubjectSubscriber(this);
  }

observers: Observer<T>[] = [];

closed = false;

isStopped = false;

hasError = false;

thrownError: any = null;

constructor() {
    super();
  }

static create: Function = <T>(destination: Observer<T>, source: Observable<T>): AnonymousSubject<T> => {
    return new AnonymousSubject<T>(destination, source);
  }

lift<R>(operator: Operator<T, R>): Observable<R> {
    const subject = new AnonymousSubject(this, this);
    subject.operator = <any>operator;
    return <any>subject;
  }

next(value?: T) {
    if (this.closed) {
      throw new ObjectUnsubscribedError();
    }
    if (!this.isStopped) {
      const { observers } = this;
      const len = observers.length;
      const copy = observers.slice();
      for (let i = 0; i < len; i++) {
        copy[i].next(value);
      }
    }
  }

error(err: any) {
    if (this.closed) {
      throw new ObjectUnsubscribedError();
    }
    this.hasError = true;
    this.thrownError = err;
    this.isStopped = true;
    const { observers } = this;
    const len = observers.length;
    const copy = observers.slice();
    for (let i = 0; i < len; i++) {
      copy[i].error(err);
    }
    this.observers.length = 0;
  }

complete() {
    if (this.closed) {
      throw new ObjectUnsubscribedError();
    }
    this.isStopped = true;
    const { observers } = this;
    const len = observers.length;
    const copy = observers.slice();
    for (let i = 0; i < len; i++) {
      copy[i].complete();
    }
    this.observers.length = 0;
  }

unsubscribe() {
    this.isStopped = true;
    this.closed = true;
    this.observers = null;
  }

protected _trySubscribe(subscriber: Subscriber<T>): TeardownLogic {
    if (this.closed) {
      throw new ObjectUnsubscribedError();
    } else {
      return super._trySubscribe(subscriber);
    }
  }

/** @deprecated internal use only */ _subscribe(subscriber: Subscriber<T>): Subscription {
    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);
    }
  }

asObservable(): Observable<T> {
    const observable = new Observable<T>();
    (<any>observable).source = this;
    return observable;
  }
}

/**
 * @class AnonymousSubject<T>
 */
export class AnonymousSubject<T> extends Subject<T> {
  constructor(protected destination?: Observer<T>, source?: Observable<T>) {
    super();
    this.source = source;
  }

next(value: T) {
    const { destination } = this;
    if (destination && destination.next) {
      destination.next(value);
    }
  }

error(err: any) {
    const { destination } = this;
    if (destination && destination.error) {
      this.destination.error(err);
    }
  }

complete() {
    const { destination } = this;
    if (destination && destination.complete) {
      this.destination.complete();
    }
  }

/** @deprecated internal use only */ _subscribe(subscriber: Subscriber<T>): Subscription {
    const { source } = this;
    if (source) {
      return this.source.subscribe(subscriber);
    } else {
      return Subscription.EMPTY;
    }
  }
}