| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent b7488c2 commit b100897
3 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -303,7 +303,7 @@ class Http2ServerRequest extends Readable { | |||
| 303 | 303 | ||
| 304 | 304 | get complete() { | |
| 305 | 305 | return this[kAborted] || | |
| 306 | - this._readableState.ended || | ||
| 306 | + this.readableEnded || | ||
| 307 | 307 | this[kState].closed || | |
| 308 | 308 | this[kStream].destroyed; | |
| 309 | 309 | } | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -207,11 +207,11 @@ class Worker extends EventEmitter { | |||
| 207 | 207 | ||
| 208 | 208 | const { stdout, stderr } = this[kParentSideStdio]; | |
| 209 | 209 | ||
| 210 | - if (!stdout._readableState.ended) { | ||
| 210 | + if (!stdout.readableEnded) { | ||
| 211 | 211 | debug(`[${threadId}] explicitly closes stdout for ${this.threadId}`); | |
| 212 | 212 | stdout.push(null); | |
| 213 | 213 | } | |
| 214 | - if (!stderr._readableState.ended) { | ||
| 214 | + if (!stderr.readableEnded) { | ||
| 215 | 215 | debug(`[${threadId}] explicitly closes stderr for ${this.threadId}`); | |
| 216 | 216 | stderr.push(null); | |
| 217 | 217 | } | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -422,7 +422,7 @@ function afterShutdown(status) { | |||
| 422 | 422 | if (self.destroyed) | |
| 423 | 423 | return; | |
| 424 | 424 | ||
| 425 | - if (!self.readable || self._readableState.ended) { | ||
| 425 | + if (!self.readable || self.readableEnded) { | ||
| 426 | 426 | debug('readableState ended, destroying'); | |
| 427 | 427 | self.destroy(); | |
| 428 | 428 | } | |
| Back | FazBrowse Home | New Git URL |
0 commit comments