diff options
author | Chetan Karande <kchetan.tech@gmail.com> | 2019-09-21 10:12:13 -0400 |
---|---|---|
committer | Daniel Bevenius <daniel.bevenius@gmail.com> | 2019-09-24 06:42:56 +0200 |
commit | fed05cc414fabb4aaacefa86df645637413164f1 (patch) | |
tree | 2141c7262a41083fa678610c675ed5c335c071a3 /lib/internal/worker.js | |
parent | 06929956f9c438d29ca127d8be147e7969bfae35 (diff) | |
download | android-node-v8-fed05cc414fabb4aaacefa86df645637413164f1.tar.gz android-node-v8-fed05cc414fabb4aaacefa86df645637413164f1.tar.bz2 android-node-v8-fed05cc414fabb4aaacefa86df645637413164f1.zip |
stream: cleanup use of internal ended state
PR-URL: https://github.com/nodejs/node/pull/29645
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>
Reviewed-By: Yongsheng Zhang <zyszys98@gmail.com>
Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de>
Diffstat (limited to 'lib/internal/worker.js')
-rw-r--r-- | lib/internal/worker.js | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/internal/worker.js b/lib/internal/worker.js index df0646ff4f..fc6588d527 100644 --- a/lib/internal/worker.js +++ b/lib/internal/worker.js @@ -207,11 +207,11 @@ class Worker extends EventEmitter { const { stdout, stderr } = this[kParentSideStdio]; - if (!stdout._readableState.ended) { + if (!stdout.readableEnded) { debug(`[${threadId}] explicitly closes stdout for ${this.threadId}`); stdout.push(null); } - if (!stderr._readableState.ended) { + if (!stderr.readableEnded) { debug(`[${threadId}] explicitly closes stderr for ${this.threadId}`); stderr.push(null); } |