1 files changed, 44 insertions, 0 deletions
diff --git a/ext/node/polyfills/internal/events/abort_listener.mjs b/ext/node/polyfills/internal/events/abort_listener.mjs
new file mode 100644
index 000000000..f1430489f
--- /dev/null
+++ b/ext/node/polyfills/internal/events/abort_listener.mjs
@@ -0,0 +1,44 @@
+// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
+// Copyright Joyent, Inc. and Node.js contributors. All rights reserved. MIT license.
+
+import { primordials } from "ext:deno_node/internal/test/binding.ts";
+const { queueMicrotask } = primordials;
+import { SymbolDispose } from "ext:deno_web/00_infra.js";
+import * as abortSignal from "ext:deno_web/03_abort_signal.js";
+import { validateAbortSignal, validateFunction } from "../validators.mjs";
+import { codes } from "../errors.ts";
+const { ERR_INVALID_ARG_TYPE } = codes;
+
+/**
+ * @param {AbortSignal} signal
+ * @param {EventListener} listener
+ * @returns {Disposable}
+ */
+function addAbortListener(signal, listener) {
+  if (signal === undefined) {
+    throw new ERR_INVALID_ARG_TYPE("signal", "AbortSignal", signal);
+  }
+  validateAbortSignal(signal, "signal");
+  validateFunction(listener, "listener");
+
+  let removeEventListener;
+  if (signal.aborted) {
+    queueMicrotask(() => listener());
+  } else {
+    signal[abortSignal.add](() => {
+      removeEventListener?.();
+      listener();
+    });
+    removeEventListener = () => {
+      signal[abortSignal.remove](listener);
+    };
+  }
+  return {
+    __proto__: null,
+    [SymbolDispose]() {
+      removeEventListener?.();
+    },
+  };
+}
+
+export { addAbortListener };