summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/internal/observable/zip.js
diff options
context:
space:
mode:
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.js4
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--;