net: use addAbortListener

PR-URL: #48550 Reviewed-By: Benjamin Gruenbaum <[email protected]> Reviewed-By: Matteo Collina <[email protected]>
nodejs · Jul 13, 2023 · ac11264 · ac11264
1 parent 002ce31
commit ac11264
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/lib/net.js b/lib/net.js
@@ -35,6 +35,7 @@ const {
   ObjectDefineProperty,
   ObjectSetPrototypeOf,
   Symbol,
+  SymbolDispose,
 } = primordials;
 
 const EventEmitter = require('events');
@@ -1605,17 +1606,18 @@ function afterConnect(status, handle, req, readable, writable) {
 function addClientAbortSignalOption(self, options) {
   validateAbortSignal(options.signal, 'options.signal');
   const { signal } = options;
+  let disposable;
 
   function onAbort() {
-    signal.removeEventListener('abort', onAbort);
+    disposable?.[SymbolDispose]();
     self._aborted = true;
   }
 
   if (signal.aborted) {
     process.nextTick(onAbort);
   } else {
     process.nextTick(() => {
-      signal.addEventListener('abort', onAbort);
+      disposable = EventEmitter.addAbortListener(signal, onAbort);
     });
   }
 }
@@ -1695,8 +1697,8 @@ function addServerAbortSignalOption(self, options) {
   if (signal.aborted) {
     process.nextTick(onAborted);
   } else {
-    signal.addEventListener('abort', onAborted);
-    self.once('close', () => signal.removeEventListener('abort', onAborted));
+    const disposable = EventEmitter.addAbortListener(signal, onAborted);
+    self.once('close', disposable[SymbolDispose]);
   }
 }