diff --git a/lib/core/util.js b/lib/core/util.js index f048398f2e9..f23db0d45fb 100644 --- a/lib/core/util.js +++ b/lib/core/util.js @@ -6,7 +6,6 @@ const { IncomingMessage } = require('node:http') const stream = require('node:stream') const net = require('node:net') const { stringify } = require('node:querystring') -const { EventEmitter: EE } = require('node:events') const timers = require('../util/timers') const { InvalidArgumentError, ConnectTimeoutError } = require('./errors') const { headerNameLowerCasedRecord } = require('./constants') @@ -43,12 +42,10 @@ function wrapRequestBody (body) { .on('data', function () { assert(false) }) - } - - if (typeof body.readableDidRead !== 'boolean') { + } else if (typeof body.readableDidRead !== 'boolean') { body[kBodyUsed] = false - EE.prototype.on.call(body, 'data', function () { - this[kBodyUsed] = true + body.once('data', () => { + body[kBodyUsed] = true }) }