diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/internal/observable/zip.js')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/internal/observable/zip.js | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/internal/observable/zip.js b/tools/node_modules/eslint/node_modules/rxjs/internal/observable/zip.js index 0d023d2f6b..1bfd530635 100644 --- a/tools/node_modules/eslint/node_modules/rxjs/internal/observable/zip.js +++ b/tools/node_modules/eslint/node_modules/rxjs/internal/observable/zip.js @@ -67,6 +67,7 @@ var ZipSubscriber = (function (_super) { ZipSubscriber.prototype._complete = function () { var iterators = this.iterators; var len = iterators.length; + this.unsubscribe(); if (len === 0) { this.destination.complete(); return; @@ -75,7 +76,8 @@ var ZipSubscriber = (function (_super) { for (var i = 0; i < len; i++) { var iterator = iterators[i]; if (iterator.stillUnsubscribed) { - this.add(iterator.subscribe(iterator, i)); + var destination = this.destination; + destination.add(iterator.subscribe(iterator, i)); } else { this.active--; |