Cleanup signal "abort" event handler in Micro.runFork (#3067)

Co-authored-by: maksim.khramtsov <maksim.khramtsov@btsdigital.kz> Co-authored-by: Tim <hello@timsmart.co>
Effect-TS · Jun 25, 2024 · 8898e5e · 8898e5e
1 parent 81027a1
commit 8898e5e
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/.changeset/eight-points-push.md b/.changeset/eight-points-push.md
@@ -0,0 +1,5 @@
+---
+"effect": patch
+---
+
+Cleanup signal "abort" event handler in `Micro.runFork`
diff --git a/packages/effect/src/Micro.ts b/packages/effect/src/Micro.ts
@@ -3672,12 +3672,15 @@ export const runFork = <A, E>(
   const handle = new HandleImpl<A, E>(controller.signal, controller)
   effect[runSymbol](envSet(env, currentAbortSignal, handle._controller.signal), (result) => {
     handle.emit(result)
+    if (options?.signal) {
+      options.signal.removeEventListener("abort", handle.unsafeAbort)
+    }
   })
   if (options?.signal) {
     if (options.signal.aborted) {
       handle.unsafeAbort()
     } else {
-      options.signal.addEventListener("abort", () => handle.unsafeAbort())
+      options.signal.addEventListener("abort", handle.unsafeAbort, { once: true })
     }
   }
   return handle