diff options
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/SubjectSubscription.js')
-rw-r--r-- | sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/SubjectSubscription.js | 26 |
1 files changed, 26 insertions, 0 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/SubjectSubscription.js b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/SubjectSubscription.js new file mode 100644 index 00000000..0f1c5df6 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/SubjectSubscription.js @@ -0,0 +1,26 @@ +import { Subscription } from './Subscription'; +export class SubjectSubscription extends Subscription { + constructor(subject, subscriber) { + super(); + this.subject = subject; + this.subscriber = subscriber; + this.closed = false; + } + unsubscribe() { + if (this.closed) { + return; + } + this.closed = true; + const subject = this.subject; + const observers = subject.observers; + this.subject = null; + if (!observers || observers.length === 0 || subject.isStopped || subject.closed) { + return; + } + const subscriberIndex = observers.indexOf(this.subscriber); + if (subscriberIndex !== -1) { + observers.splice(subscriberIndex, 1); + } + } +} +//# sourceMappingURL=SubjectSubscription.js.map
\ No newline at end of file |