@@ -249,13 +249,13 @@ function writeHead(statusCode, reason, obj) {
249249 }
250250 this . statusCode = statusCode ;
251251
252- var headers ;
252+ let headers ;
253253 if ( this [ kOutHeaders ] ) {
254254 // Slow-case: when progressive API and header fields are passed.
255- var k ;
255+ let k ;
256256 if ( obj ) {
257- var keys = Object . keys ( obj ) ;
258- for ( var i = 0 ; i < keys . length ; i ++ ) {
257+ const keys = Object . keys ( obj ) ;
258+ for ( let i = 0 ; i < keys . length ; i ++ ) {
259259 k = keys [ i ] ;
260260 if ( k ) this . setHeader ( k , obj [ k ] ) ;
261261 }
@@ -483,7 +483,7 @@ function socketOnClose(socket, state) {
483483
484484function abortIncoming ( incoming ) {
485485 while ( incoming . length ) {
486- var req = incoming . shift ( ) ;
486+ const req = incoming . shift ( ) ;
487487 req . aborted = true ;
488488 req . emit ( 'aborted' ) ;
489489 req . emit ( 'close' ) ;
@@ -573,8 +573,7 @@ function onParserExecuteCommon(server, socket, parser, state, ret, d) {
573573 socketOnError . call ( socket , ret ) ;
574574 } else if ( parser . incoming && parser . incoming . upgrade ) {
575575 // Upgrade or CONNECT
576- var bytesParsed = ret ;
577- var req = parser . incoming ;
576+ const req = parser . incoming ;
578577 debug ( 'SERVER upgrade or connect' , req . method ) ;
579578
580579 if ( ! d )
@@ -591,10 +590,10 @@ function onParserExecuteCommon(server, socket, parser, state, ret, d) {
591590 freeParser ( parser , req , socket ) ;
592591 parser = null ;
593592
594- var eventName = req . method === 'CONNECT' ? 'connect' : 'upgrade' ;
593+ const eventName = req . method === 'CONNECT' ? 'connect' : 'upgrade' ;
595594 if ( eventName === 'upgrade' || server . listenerCount ( eventName ) > 0 ) {
596595 debug ( 'SERVER have listener for %s' , eventName ) ;
597- var bodyHead = d . slice ( bytesParsed , d . length ) ;
596+ const bodyHead = d . slice ( ret , d . length ) ;
598597
599598 socket . readableFlowing = null ;
600599 server . emit ( eventName , req , socket , bodyHead ) ;
@@ -656,7 +655,7 @@ function resOnFinish(req, res, socket, state, server) {
656655 }
657656 } else {
658657 // Start sending the next message
659- var m = state . outgoing . shift ( ) ;
658+ const m = state . outgoing . shift ( ) ;
660659 if ( m ) {
661660 m . assignSocket ( socket ) ;
662661 }
@@ -693,7 +692,7 @@ function parserOnIncoming(server, socket, state, req, keepAlive) {
693692 // so that we don't become overwhelmed by a flood of
694693 // pipelined requests that may never be resolved.
695694 if ( ! socket . _paused ) {
696- var ws = socket . _writableState ;
695+ const ws = socket . _writableState ;
697696 if ( ws . needDrain || state . outgoingData >= socket . writableHighWaterMark ) {
698697 socket . _paused = true ;
699698 // We also need to pause the parser, but don't do that until after
0 commit comments