Commit 8362caa
dgram: 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 562369f commit 8362caa
1 file changed
Lines changed: 2 additions & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -63,6 +63,7 @@ const { Buffer } = require('buffer'); | |||
| 63 | 63 | const { deprecate, guessHandleType, promisify } = require('internal/util'); | |
| 64 | 64 | const { isArrayBufferView } = require('internal/util/types'); | |
| 65 | 65 | const EventEmitter = require('events'); | |
| 66 | + const { addAbortListener } = require('internal/events/abort_listener'); | ||
| 66 | 67 | const { | |
| 67 | 68 | defaultTriggerAsyncIdScope, | |
| 68 | 69 | symbols: { async_id_symbol, owner_symbol }, | |
@@ -146,7 +147,7 @@ function Socket(type, listener) { | |||
| 146 | 147 | if (signal.aborted) { | |
| 147 | 148 | onAborted(); | |
| 148 | 149 | } else { | |
| 149 | - const disposable = EventEmitter.addAbortListener(signal, onAborted); | ||
| 150 | + const disposable = addAbortListener(signal, onAborted); | ||
| 150 | 151 | this.once('close', disposable[SymbolDispose]); | |
| 151 | 152 | } | |
| 152 | 153 | } | |
0 commit comments