diff options
| -rw-r--r-- | lib/internal/http2/compat.js | 2 | ||||
| -rw-r--r-- | lib/internal/worker.js | 4 | ||||
| -rw-r--r-- | lib/net.js | 2 |
3 files changed, 4 insertions, 4 deletions
diff --git a/lib/internal/http2/compat.js b/lib/internal/http2/compat.js index 9cf19250a8..2d6ed47d74 100644 --- a/lib/internal/http2/compat.js +++ b/lib/internal/http2/compat.js @@ -303,7 +303,7 @@ class Http2ServerRequest extends Readable { get complete() { return this[kAborted] || - this._readableState.ended || + this.readableEnded || this[kState].closed || this[kStream].destroyed; } 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); } diff --git a/lib/net.js b/lib/net.js index 1eb1d212cd..760bf084f4 100644 --- a/lib/net.js +++ b/lib/net.js @@ -422,7 +422,7 @@ function afterShutdown(status) { if (self.destroyed) return; - if (!self.readable || self._readableState.ended) { + if (!self.readable || self.readableEnded) { debug('readableState ended, destroying'); self.destroy(); } |