fix: allow interruptions to be expressed in the state

tim-smart · Feb 7, 2024 · dde7a40 · dde7a40
1 parent 1d6a8e0
commit dde7a40
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/.changeset/nine-ads-play.md b/.changeset/nine-ads-play.md
@@ -0,0 +1,5 @@
+---
+"@effect-rx/rx": patch
+---
+
+Acknowledge interruptions
diff --git a/packages/rx/src/Rx.ts b/packages/rx/src/Rx.ts
@@ -463,9 +463,7 @@ function makeEffect<E, A>(
   const cancel = runCallbackSync(runtime)(
     scopedEffect,
     function(exit) {
-      if (!Exit.isInterrupted(exit)) {
-        ctx.setSelfSync(Result.fromExitWithPrevious(exit, previous))
-      }
+      ctx.setSelfSync(Result.fromExitWithPrevious(exit, previous))
     }
   )
   if (cancel !== undefined) {