ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / local / lib / node_modules / ghost-cli / node_modules / rxjs / src / internal

import { Subject } from './Subject';
import { Subscriber } from './Subscriber';
import { Subscription } from './Subscription';
import { SubscriptionLike } from './types';
import { ObjectUnsubscribedError } from './util/ObjectUnsubscribedError';

/**
 * A variant of Subject that requires an initial value and emits its current
 * value whenever it is subscribed to.
 *
 * @class BehaviorSubject<T>
 */
export class BehaviorSubject<T> extends Subject<T> {

constructor(private _value: T) {
    super();
  }

get value(): T {
    return this.getValue();
  }

/** @deprecated This is an internal implementation detail, do not use. */
  _subscribe(subscriber: Subscriber<T>): Subscription {
    const subscription = super._subscribe(subscriber);
    if (subscription && !(<SubscriptionLike>subscription).closed) {
      subscriber.next(this._value);
    }
    return subscription;
  }

getValue(): T {
    if (this.hasError) {
      throw this.thrownError;
    } else if (this.closed) {
      throw new ObjectUnsubscribedError();
    } else {
      return this._value;
    }
  }

next(value: T): void {
    super.next(this._value = value);
  }
}

[+] scheduled
[-] Observable.ts [edit]
[+] ..
[-] BehaviorSubject.ts [edit]
[+] testing
[-] Scheduler.ts [edit]
[-] AsyncSubject.ts [edit]
[+] observable
[-] Subscription.ts [edit]
[-] ReplaySubject.ts [edit]
[-] InnerSubscriber.ts [edit]
[+] scheduler
[+] symbol
[-] Subject.ts [edit]
[-] SubjectSubscription.ts [edit]
[-] config.ts [edit]
[+] util
[-] OuterSubscriber.ts [edit]
[-] Operator.ts [edit]
[-] Subscriber.ts [edit]
[-] Rx.ts [edit]
[-] types.ts [edit]
[+] operators
[-] Notification.ts [edit]
[-] umd.ts [edit]
[-] Observer.ts [edit]