aboutsummaryrefslogtreecommitdiff
path: root/sandbox/testAppNevena/Front/node_modules/rxjs/_esm2015/internal/SubjectSubscription.js
diff options
context:
space:
mode:
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.js26
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