Commit d89fc73
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 8362caa commit d89fc73
1 file changed
Lines changed: 3 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -41,6 +41,7 @@ const { | |||
| 41 | 41 | } = primordials; | |
| 42 | 42 | ||
| 43 | 43 | const EventEmitter = require('events'); | |
| 44 | + const { addAbortListener } = require('internal/events/abort_listener'); | ||
| 44 | 45 | const stream = require('stream'); | |
| 45 | 46 | let debug = require('internal/util/debuglog').debuglog('net', (fn) => { | |
| 46 | 47 | debug = fn; | |
@@ -1631,7 +1632,7 @@ function addClientAbortSignalOption(self, options) { | |||
| 1631 | 1632 | process.nextTick(onAbort); | |
| 1632 | 1633 | } else { | |
| 1633 | 1634 | process.nextTick(() => { | |
| 1634 | - disposable = EventEmitter.addAbortListener(signal, onAbort); | ||
| 1635 | + disposable = addAbortListener(signal, onAbort); | ||
| 1635 | 1636 | }); | |
| 1636 | 1637 | } | |
| 1637 | 1638 | } | |
@@ -1723,7 +1724,7 @@ function addServerAbortSignalOption(self, options) { | |||
| 1723 | 1724 | if (signal.aborted) { | |
| 1724 | 1725 | process.nextTick(onAborted); | |
| 1725 | 1726 | } else { | |
| 1726 | - const disposable = EventEmitter.addAbortListener(signal, onAborted); | ||
| 1727 | + const disposable = addAbortListener(signal, onAborted); | ||
| 1727 | 1728 | self.once('close', disposable[SymbolDispose]); | |
| 1728 | 1729 | } | |
| 1729 | 1730 | } | |
0 commit comments