From dde7a40443b7255edff0408cd9acc5e7235bab48 Mon Sep 17 00:00:00 2001
From: Yuval Datner <22598347+datner@users.noreply.github.com>
Date: Wed, 7 Feb 2024 14:45:18 +0700
Subject: [PATCH] fix: allow interruptions to be expressed in the state

---
 .changeset/nine-ads-play.md | 5 +++++
 packages/rx/src/Rx.ts       | 4 +---
 2 files changed, 6 insertions(+), 3 deletions(-)
 create mode 100644 .changeset/nine-ads-play.md

diff --git a/.changeset/nine-ads-play.md b/.changeset/nine-ads-play.md
new file mode 100644
index 0000000..b2b5fea
--- /dev/null
+++ 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
index 8762deb..cbd0ef5 100644
--- 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) {