summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeMap.js
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeMap.js')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeMap.js4
1 files changed, 3 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeMap.js b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeMap.js
index fe6fa5db53..7d47338367 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeMap.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeMap.js
@@ -54,7 +54,8 @@ export class MergeMapSubscriber extends OuterSubscriber {
}
_innerSub(ish, value, index) {
const innerSubscriber = new InnerSubscriber(this, undefined, undefined);
- this.add(innerSubscriber);
+ const destination = this.destination;
+ destination.add(innerSubscriber);
subscribeToResult(this, ish, value, index, innerSubscriber);
}
_complete() {
@@ -62,6 +63,7 @@ export class MergeMapSubscriber extends OuterSubscriber {
if (this.active === 0 && this.buffer.length === 0) {
this.destination.complete();
}
+ this.unsubscribe();
}
notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
this.destination.next(innerValue);