@@ -116,6 +116,7 @@ let debug = require('internal/util/debuglog').debuglog('http', (fn) => {
116116const INVALID_PATH_REGEX = / [ ^ \u0021 - \u00ff ] / ;
117117const kError = Symbol ( 'kError' ) ;
118118const kImmediateError = Symbol ( 'kImmediateError' ) ;
119+ const kOnImmediateError = Symbol ( 'kOnImmediateError' ) ;
119120
120121const kLenientAll = HTTPParser . kLenientAll | 0 ;
121122const kLenientNone = HTTPParser . kLenientNone | 0 ;
@@ -899,7 +900,7 @@ function tickOnSocket(req, socket) {
899900 parser . joinDuplicateHeaders = req . joinDuplicateHeaders ;
900901
901902 parser . onIncoming = parserOnIncomingClient ;
902- socket . removeListener ( 'error' , socket . onImmediateError ) ;
903+ socket . removeListener ( 'error' , socket [ kOnImmediateError ] ) ;
903904 socket . on ( 'error' , socketErrorListener ) ;
904905 socket . on ( 'data' , socketOnData ) ;
905906 socket . on ( 'end' , socketOnEnd ) ;
@@ -942,10 +943,10 @@ ClientRequest.prototype.onSocket = function onSocket(socket, err) {
942943 const req = this ;
943944
944945 if ( ! err && socket ) {
945- socket . onImmediateError = function onImmediateError ( err ) {
946+ socket [ kOnImmediateError ] = function onImmediateError ( err ) {
946947 req [ kImmediateError ] = err ;
947948 }
948- socket . on ( 'error' , socket . onImmediateError ) ;
949+ socket . on ( 'error' , socket [ kOnImmediateError ] ) ;
949950 }
950951
951952 process . nextTick ( onSocketNT , this , socket , err ) ;
@@ -968,7 +969,7 @@ function onSocketNT(req, socket, err) {
968969 }
969970
970971 if ( socket ) {
971- socket . removeListener ( 'error' , socket . onImmediateError ) ;
972+ socket . removeListener ( 'error' , socket [ kOnImmediateError ] ) ;
972973 if ( ! err && req . agent && ! socket . destroyed ) {
973974 socket . emit ( 'free' ) ;
974975 } else {
0 commit comments