From e4450c8417624b71d779cb4f41692538f9165e10 Mon Sep 17 00:00:00 2001
From: sowgro <tpoke.ferrari@gmail.com>
Date: Sat, 2 Sep 2023 19:12:47 -0400
Subject: first commit
---
node_modules/undici/lib/api/abort-signal.js | 57 +++++++++++++++++++++++++++++
1 file changed, 57 insertions(+)
create mode 100644 node_modules/undici/lib/api/abort-signal.js
(limited to 'node_modules/undici/lib/api/abort-signal.js')
diff --git a/node_modules/undici/lib/api/abort-signal.js b/node_modules/undici/lib/api/abort-signal.js
new file mode 100644
index 0000000..895629a
--- /dev/null
+++ b/node_modules/undici/lib/api/abort-signal.js
@@ -0,0 +1,57 @@
+const { RequestAbortedError } = require('../core/errors')
+
+const kListener = Symbol('kListener')
+const kSignal = Symbol('kSignal')
+
+function abort (self) {
+ if (self.abort) {
+ self.abort()
+ } else {
+ self.onError(new RequestAbortedError())
+ }
+}
+
+function addSignal (self, signal) {
+ self[kSignal] = null
+ self[kListener] = null
+
+ if (!signal) {
+ return
+ }
+
+ if (signal.aborted) {
+ abort(self)
+ return
+ }
+
+ self[kSignal] = signal
+ self[kListener] = () => {
+ abort(self)
+ }
+
+ if ('addEventListener' in self[kSignal]) {
+ self[kSignal].addEventListener('abort', self[kListener])
+ } else {
+ self[kSignal].addListener('abort', self[kListener])
+ }
+}
+
+function removeSignal (self) {
+ if (!self[kSignal]) {
+ return
+ }
+
+ if ('removeEventListener' in self[kSignal]) {
+ self[kSignal].removeEventListener('abort', self[kListener])
+ } else {
+ self[kSignal].removeListener('abort', self[kListener])
+ }
+
+ self[kSignal] = null
+ self[kListener] = null
+}
+
+module.exports = {
+ addSignal,
+ removeSignal
+}
--
cgit v1.2.3