Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
dom	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
ArrayLikeObservable.ts	1.89 KB	-rw-rw-r--	2022-08-30 11:49
ArrayObservable.ts	4.29 KB	-rw-rw-r--	2022-08-30 11:49
BoundCallbackObservable.ts	14.32 KB	-rw-rw-r--	2022-08-30 11:49
BoundNodeCallbackObservable.ts	12.27 KB	-rw-rw-r--	2022-08-30 11:49
ConnectableObservable.ts	5.58 KB	-rw-rw-r--	2022-08-30 11:49
DeferObservable.ts	3.3 KB	-rw-rw-r--	2022-08-30 11:49
EmptyObservable.ts	2.51 KB	-rw-rw-r--	2022-08-30 11:49
ErrorObservable.ts	2.61 KB	-rw-rw-r--	2022-08-30 11:49
ForkJoinObservable.ts	10.66 KB	-rw-rw-r--	2022-08-30 11:49
FromEventObservable.ts	10.89 KB	-rw-rw-r--	2022-08-30 11:49
FromEventPatternObservable.ts	3.71 KB	-rw-rw-r--	2022-08-30 11:49
FromObservable.ts	4.34 KB	-rw-rw-r--	2022-08-30 11:49
GenerateObservable.ts	9.73 KB	-rw-rw-r--	2022-08-30 11:49
IfObservable.ts	1.84 KB	-rw-rw-r--	2022-08-30 11:49
IntervalObservable.ts	2.67 KB	-rw-rw-r--	2022-08-30 11:49
IteratorObservable.ts	3.69 KB	-rw-rw-r--	2022-08-30 11:49
NeverObservable.ts	1.6 KB	-rw-rw-r--	2022-08-30 11:49
PairsObservable.ts	2.63 KB	-rw-rw-r--	2022-08-30 11:49
PromiseObservable.ts	3.87 KB	-rw-rw-r--	2022-08-30 11:49
RangeObservable.ts	2.87 KB	-rw-rw-r--	2022-08-30 11:49
ScalarObservable.ts	1.32 KB	-rw-rw-r--	2022-08-30 11:49
SubscribeOnObservable.ts	1.51 KB	-rw-rw-r--	2022-08-30 11:49
TimerObservable.ts	3.8 KB	-rw-rw-r--	2022-08-30 11:49
UsingObservable.ts	1.88 KB	-rw-rw-r--	2022-08-30 11:49
bindCallback.ts	131 B	-rw-rw-r--	2022-08-30 11:49
bindNodeCallback.ts	147 B	-rw-rw-r--	2022-08-30 11:49
combineLatest.ts	9.79 KB	-rw-rw-r--	2022-08-30 11:49
concat.ts	6.04 KB	-rw-rw-r--	2022-08-30 11:49
defer.ts	100 B	-rw-rw-r--	2022-08-30 11:49
empty.ts	100 B	-rw-rw-r--	2022-08-30 11:49
forkJoin.ts	112 B	-rw-rw-r--	2022-08-30 11:49
from.ts	96 B	-rw-rw-r--	2022-08-30 11:49
fromEvent.ts	116 B	-rw-rw-r--	2022-08-30 11:49
fromEventPattern.ts	144 B	-rw-rw-r--	2022-08-30 11:49
fromPromise.ts	112 B	-rw-rw-r--	2022-08-30 11:49
generate.ts	111 B	-rw-rw-r--	2022-08-30 11:49
if.ts	89 B	-rw-rw-r--	2022-08-30 11:49
interval.ts	112 B	-rw-rw-r--	2022-08-30 11:49
merge.ts	6.14 KB	-rw-rw-r--	2022-08-30 11:49
never.ts	100 B	-rw-rw-r--	2022-08-30 11:49
of.ts	93 B	-rw-rw-r--	2022-08-30 11:49
onErrorResumeNext.ts	133 B	-rw-rw-r--	2022-08-30 11:49
pairs.ts	102 B	-rw-rw-r--	2022-08-30 11:49
race.ts	3.17 KB	-rw-rw-r--	2022-08-30 11:49
range.ts	100 B	-rw-rw-r--	2022-08-30 11:49
throw.ts	101 B	-rw-rw-r--	2022-08-30 11:49
timer.ts	100 B	-rw-rw-r--	2022-08-30 11:49
using.ts	100 B	-rw-rw-r--	2022-08-30 11:49
zip.ts	79 B	-rw-rw-r--	2022-08-30 11:49

Rename

import { Subject, SubjectSubscriber } from '../Subject';
import { Operator } from '../Operator';
import { Observable } from '../Observable';
import { Subscriber } from '../Subscriber';
import { Subscription, TeardownLogic } from '../Subscription';
import { refCount as higherOrderRefCount } from '../operators/refCount';

/**
 * @class ConnectableObservable<T>
 */
export class ConnectableObservable<T> extends Observable<T> {

/** @deprecated internal use only */ public _subject: Subject<T>;
  /** @deprecated internal use only */ public _refCount: number = 0;
  /** @deprecated internal use only */ public _connection: Subscription;
  _isComplete = false;

constructor(/** @deprecated internal use only */ public source: Observable<T>,
              /** @deprecated internal use only */ public subjectFactory: () => Subject<T>) {
    super();
  }

/** @deprecated internal use only */ _subscribe(subscriber: Subscriber<T>) {
    return this.getSubject().subscribe(subscriber);
  }

/** @deprecated internal use only */ public getSubject(): Subject<T> {
    const subject = this._subject;
    if (!subject || subject.isStopped) {
      this._subject = this.subjectFactory();
    }
    return this._subject;
  }

connect(): Subscription {
    let connection = this._connection;
    if (!connection) {
      this._isComplete = false;
      connection = this._connection = new Subscription();
      connection.add(this.source
        .subscribe(new ConnectableSubscriber(this.getSubject(), this)));
      if (connection.closed) {
        this._connection = null;
        connection = Subscription.EMPTY;
      } else {
        this._connection = connection;
      }
    }
    return connection;
  }

refCount(): Observable<T> {
    return higherOrderRefCount()(this) as Observable<T>;
  }
}

const connectableProto = <any>ConnectableObservable.prototype;

export const connectableObservableDescriptor: PropertyDescriptorMap = {
  operator: { value: null },
  _refCount: { value: 0, writable: true },
  _subject: { value: null, writable: true },
  _connection: { value: null, writable: true },
  _subscribe: { value: connectableProto._subscribe },
  _isComplete: { value: connectableProto._isComplete, writable: true },
  getSubject: { value: connectableProto.getSubject },
  connect: { value: connectableProto.connect },
  refCount: { value: connectableProto.refCount }
};

class ConnectableSubscriber<T> extends SubjectSubscriber<T> {
  constructor(destination: Subject<T>,
              private connectable: ConnectableObservable<T>) {
    super(destination);
  }
  protected _error(err: any): void {
    this._unsubscribe();
    super._error(err);
  }
  protected _complete(): void {
    this.connectable._isComplete = true;
    this._unsubscribe();
    super._complete();
  }
  /** @deprecated internal use only */ _unsubscribe() {
    const connectable = <any>this.connectable;
    if (connectable) {
      this.connectable = null;
      const connection = connectable._connection;
      connectable._refCount = 0;
      connectable._subject = null;
      connectable._connection = null;
      if (connection) {
        connection.unsubscribe();
      }
    }
  }
}

class RefCountOperator<T> implements Operator<T, T> {
  constructor(private connectable: ConnectableObservable<T>) {
  }
  call(subscriber: Subscriber<T>, source: any): TeardownLogic {

const { connectable } = this;
    (<any> connectable)._refCount++;

const refCounter = new RefCountSubscriber(subscriber, connectable);
    const subscription = source.subscribe(refCounter);

if (!refCounter.closed) {
      (<any> refCounter).connection = connectable.connect();
    }

return subscription;
  }
}

class RefCountSubscriber<T> extends Subscriber<T> {

private connection: Subscription;

constructor(destination: Subscriber<T>,
              private connectable: ConnectableObservable<T>) {
    super(destination);
  }

/** @deprecated internal use only */ _unsubscribe() {

const { connectable } = this;
    if (!connectable) {
      this.connection = null;
      return;
    }

this.connectable = null;
    const refCount = (<any> connectable)._refCount;
    if (refCount <= 0) {
      this.connection = null;
      return;
    }

(<any> connectable)._refCount = refCount - 1;
    if (refCount > 1) {
      this.connection = null;
      return;
    }

///
    // Compare the local RefCountSubscriber's connection Subscription to the
    // connection Subscription on the shared ConnectableObservable. In cases
    // where the ConnectableObservable source synchronously emits values, and
    // the RefCountSubscriber's downstream Observers synchronously unsubscribe,
    // execution continues to here before the RefCountOperator has a chance to
    // supply the RefCountSubscriber with the shared connection Subscription.
    // For example:
    // ```
    // Observable.range(0, 10)
    //   .publish()
    //   .refCount()
    //   .take(5)
    //   .subscribe();
    // ```
    // In order to account for this case, RefCountSubscriber should only dispose
    // the ConnectableObservable's shared connection Subscription if the
    // connection Subscription exists, *and* either:
    //   a. RefCountSubscriber doesn't have a reference to the shared connection
    //      Subscription yet, or,
    //   b. RefCountSubscriber's connection Subscription reference is identical
    //      to the shared connection Subscription
    ///
    const { connection } = this;
    const sharedConnection = (<any> connectable)._connection;
    this.connection = null;

if (sharedConnection && (!connection || sharedConnection === connection)) {
      sharedConnection.unsubscribe();
    }
  }
}