@@ -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 ) ;
0 commit comments