don't interrupt queries

Effect-TS · Dec 4, 2024 · 2d385a4 · 2d385a4
1 parent a184ecc
commit 2d385a4
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/packages/experimental/src/Reactivity.ts b/packages/experimental/src/Reactivity.ts
@@ -1,7 +1,6 @@
 /**
  * @since 1.0.0
  */
-import * as Cause from "effect/Cause"
 import * as Context from "effect/Context"
 import * as Effect from "effect/Effect"
 import * as Exit from "effect/Exit"
@@ -75,7 +74,6 @@ export const make = Effect.sync(() => {
 
       const handledEffect = Effect.matchCause(effect, {
         onFailure(cause) {
-          if (Cause.isInterruptedOnly(cause)) return
           results.unsafeDone(Exit.failCause(cause))
         },
         onSuccess(a) {
@@ -84,7 +82,7 @@ export const make = Effect.sync(() => {
       })
 
       function run() {
-        runFork(handledEffect)
+        runFork(handledEffect, { onlyIfMissing: true })
       }
 
       yield* Scope.addFinalizer(