summaryrefslogtreecommitdiff
path: root/lib/internal/worker.js
diff options
context:
space:
mode:
authorChetan Karande <kchetan.tech@gmail.com>2019-09-21 10:12:13 -0400
committerDaniel Bevenius <daniel.bevenius@gmail.com>2019-09-24 06:42:56 +0200
commitfed05cc414fabb4aaacefa86df645637413164f1 (patch)
tree2141c7262a41083fa678610c675ed5c335c071a3 /lib/internal/worker.js
parent06929956f9c438d29ca127d8be147e7969bfae35 (diff)
downloadandroid-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.js4
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);
}