diff options
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.js | 4 |
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); |