diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/BehaviorSubject.ts')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/src/internal/BehaviorSubject.ts | 45 |
1 files changed, 0 insertions, 45 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/BehaviorSubject.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/BehaviorSubject.ts deleted file mode 100644 index 20de21c668..0000000000 --- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/BehaviorSubject.ts +++ /dev/null @@ -1,45 +0,0 @@ -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); - } -} |