| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -122,20 +122,6 @@ function onStreamDrain() { | |||
| 122 | 122 | response.emit('drain'); | |
| 123 | 123 | } | |
| 124 | 124 | ||
| 125 | - // TODO Http2Stream does not emit 'close' | ||
| 126 | - function onStreamClosedRequest() { | ||
| 127 | - const request = this[kRequest]; | ||
| 128 | - if (request !== undefined) | ||
| 129 | - request.push(null); | ||
| 130 | - } | ||
| 131 | - | ||
| 132 | - // TODO Http2Stream does not emit 'close' | ||
| 133 | - function onStreamClosedResponse() { | ||
| 134 | - const response = this[kResponse]; | ||
| 135 | - if (response !== undefined) | ||
| 136 | - response.emit('finish'); | ||
| 137 | - } | ||
| 138 | - | ||
| 139 | 125 | function onStreamAbortedRequest() { | |
| 140 | 126 | const request = this[kRequest]; | |
| 141 | 127 | if (request !== undefined && request[kState].closed === false) { | |
@@ -247,7 +233,6 @@ class Http2ServerRequest extends Readable { | |||
| 247 | 233 | stream.on('trailers', onStreamTrailers); | |
| 248 | 234 | stream.on('end', onStreamEnd); | |
| 249 | 235 | stream.on('error', onStreamError); | |
| 250 | - stream.on('close', onStreamClosedRequest); | ||
| 251 | 236 | stream.on('aborted', onStreamAbortedRequest); | |
| 252 | 237 | const onfinish = this[kFinish].bind(this); | |
| 253 | 238 | stream.on('close', onfinish); | |
@@ -380,7 +365,6 @@ class Http2ServerResponse extends Stream { | |||
| 380 | 365 | stream[kResponse] = this; | |
| 381 | 366 | this.writable = true; | |
| 382 | 367 | stream.on('drain', onStreamDrain); | |
| 383 | - stream.on('close', onStreamClosedResponse); | ||
| 384 | 368 | stream.on('aborted', onStreamAbortedResponse); | |
| 385 | 369 | const onfinish = this[kFinish].bind(this); | |
| 386 | 370 | stream.on('close', onfinish); | |
| Back | FazBrowse Home | New Git URL |
0 commit comments