summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/src/internal/BehaviorSubject.ts
diff options
context:
space:
mode:
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.ts45
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);
- }
-}