Add { once: true } to all "abort" event listeners for `AbortContr…

…oller` to automatically remove handlers after execution

.changeset/silver-taxis-cover.md

@@ -0,0 +1,8 @@
+---
+"@effect/platform-browser": patch
+"@effect/platform-bun": patch
+"@effect/platform": patch
+"effect": patch
+---
+
+Add `{ once: true }` to all `"abort"` event listeners for `AbortController` to automatically remove handlers after execution

packages/effect/src/internal/runtime.ts

@@ -290,7 +290,7 @@ export const unsafeRunPromiseExit = <R>(runtime: Runtime.Runtime<R>) =>
       } else {
         options.signal.addEventListener("abort", () => {
           fiber.unsafeInterruptAsFork(fiber.id())
-        })
+        }, { once: true })
       }
     }
   })

packages/effect/test/Effect/promise.test.ts

@@ -28,7 +28,7 @@ describe("Effect", () => {
     const effect = Effect.promise<void>((signal) => {
       signal.addEventListener("abort", () => {
         aborted = true
-      })
+      }, { once: true })
       return new Promise((resolve) => {
         setTimeout(() => {
           resolve()

packages/effect/test/Effect/tryPromise.test.ts

@@ -47,7 +47,7 @@ describe("Effect", () => {
     const effect = Effect.tryPromise<void>((signal) => {
       signal.addEventListener("abort", () => {
         aborted = true
-      })
+      }, { once: true })
       return new Promise((resolve) => {
         setTimeout(() => {
           resolve()
@@ -70,7 +70,7 @@ describe("Effect", () => {
       try: (signal) => {
         signal.addEventListener("abort", () => {
           aborted = true
-        })
+        }, { once: true })
         return new Promise((resolve) => {
           setTimeout(() => {
             resolve()

packages/platform-browser/src/internal/http/client.ts

@@ -43,7 +43,7 @@ export const makeXMLHttpRequest = Client.makeDefault((request, url, signal, fibe
     signal.addEventListener("abort", () => {
       xhr.abort()
       xhr.onreadystatechange = null
-    })
+    }, { once: true })
     xhr.open(request.method, url.toString(), true)
     xhr.responseType = fiber.getFiberRef(currentXHRResponseType)
     Object.entries(request.headers).forEach(([k, v]) => {

packages/platform-bun/src/internal/http/server.ts

@@ -102,7 +102,7 @@ export const make = (
                   ))
                   request.signal.addEventListener("abort", () => {
                     runFork(fiber.interruptAsFork(Error.clientAbortFiberId))
-                  })
+                  }, { once: true })
                 })
               }
               handlerStack.push(handler)

packages/platform/src/Http/App.ts

@@ -155,7 +155,7 @@ export const toWebHandlerRuntime = <R>(runtime: Runtime.Runtime<R>) => {
         const fiber = run(Effect.provideService(handled, ServerRequest.ServerRequest, req))
         request.signal.addEventListener("abort", () => {
           fiber.unsafeInterruptAsFork(ServerError.clientAbortFiberId)
-        })
+        }, { once: true })
       })
   }
 }