tweak stream interrupt check

tim-smart · Sep 21, 2023 · c0c51e7 · c0c51e7
1 parent 54b12e7
commit c0c51e7
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/packages/rx/src/Rx.ts b/packages/rx/src/Rx.ts
@@ -474,12 +474,10 @@ function makeStream<E, A>(
       (a) => Effect.sync(() => ctx.setSelf(Result.waiting(Result.success(a))))
     ),
     (exit) => {
-      if (Exit.isInterrupted(exit)) {
-        return
-      }
-
       if (exit._tag === "Failure") {
-        ctx.setSelf(Result.failure(exit.cause))
+        if (!Exit.isInterrupted(exit)) {
+          ctx.setSelf(Result.failure(exit.cause))
+        }
       } else {
         pipe(
           ctx.self<Result.Result<E | NoSuchElementException, A>>(),