Skip to content

Commit f668734

Browse files
atlowChemimarco-ippolito
authored andcommitted
net: use internal addAbortListener
PR-URL: #52081 Refs: #48596 Reviewed-By: Moshe Atlow <moshe@atlow.co.il> Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com> Reviewed-By: Antoine du Hamel <duhamelantoine1995@gmail.com> Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
1 parent d592c58 commit f668734

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

lib/net.js

+3-2
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@ const {
4141
} = primordials;
4242

4343
const EventEmitter = require('events');
44+
const { addAbortListener } = require('internal/events/abort_listener');
4445
const stream = require('stream');
4546
let debug = require('internal/util/debuglog').debuglog('net', (fn) => {
4647
debug = fn;
@@ -1631,7 +1632,7 @@ function addClientAbortSignalOption(self, options) {
16311632
process.nextTick(onAbort);
16321633
} else {
16331634
process.nextTick(() => {
1634-
disposable = EventEmitter.addAbortListener(signal, onAbort);
1635+
disposable = addAbortListener(signal, onAbort);
16351636
});
16361637
}
16371638
}
@@ -1723,7 +1724,7 @@ function addServerAbortSignalOption(self, options) {
17231724
if (signal.aborted) {
17241725
process.nextTick(onAborted);
17251726
} else {
1726-
const disposable = EventEmitter.addAbortListener(signal, onAborted);
1727+
const disposable = addAbortListener(signal, onAborted);
17271728
self.once('close', disposable[SymbolDispose]);
17281729
}
17291730
}

0 commit comments

Comments
 (0)