aboutsummaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/observable/zip.js
diff options
context:
space:
mode:
authorcjihrig <cjihrig@gmail.com>2018-09-28 14:58:09 -0400
committerDaniel Bevenius <daniel.bevenius@gmail.com>2018-10-01 09:46:40 +0200
commitbb00eda910b4f94959e01966b87a4d716e672dcf (patch)
tree603b5da62fb5cb9ec43bbac65847ad57dbd7b8d0 /tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/observable/zip.js
parent5c855a7334e27fdff2fde9eae084adf588e1a135 (diff)
downloadandroid-node-v8-bb00eda910b4f94959e01966b87a4d716e672dcf.tar.gz
android-node-v8-bb00eda910b4f94959e01966b87a4d716e672dcf.tar.bz2
android-node-v8-bb00eda910b4f94959e01966b87a4d716e672dcf.zip
tools: update ESLint to 5.6.1
Update ESLint to 5.6.1. PR-URL: https://github.com/nodejs/node/pull/23149 Reviewed-By: Rich Trott <rtrott@gmail.com> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com> Reviewed-By: Roman Reiss <me@silverwind.io>
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/observable/zip.js')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/observable/zip.js4
1 files changed, 3 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/observable/zip.js b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/observable/zip.js
index 5fccb62b2b..076ef5bc10 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/observable/zip.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/observable/zip.js
@@ -42,6 +42,7 @@ export class ZipSubscriber extends Subscriber {
_complete() {
const iterators = this.iterators;
const len = iterators.length;
+ this.unsubscribe();
if (len === 0) {
this.destination.complete();
return;
@@ -50,7 +51,8 @@ export class ZipSubscriber extends Subscriber {
for (let i = 0; i < len; i++) {
let iterator = iterators[i];
if (iterator.stillUnsubscribed) {
- this.add(iterator.subscribe(iterator, i));
+ const destination = this.destination;
+ destination.add(iterator.subscribe(iterator, i));
}
else {
this.active--;