allow Stream run fiber to close before trying to interrupt it (#3176)

Effect-TS · Jul 4, 2024 · b5554db · b5554db
1 parent a9c4fb3
commit b5554db
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/.changeset/few-pears-reply.md b/.changeset/few-pears-reply.md
@@ -0,0 +1,5 @@
+---
+"effect": patch
+---
+
+allow Stream run fiber to close before trying to interrupt it
diff --git a/packages/effect/src/internal/channel/channelExecutor.ts b/packages/effect/src/internal/channel/channelExecutor.ts
@@ -1141,7 +1141,12 @@ export const runScoped = <Env, InErr, InDone, OutErr, OutDone>(
             Effect.forkScoped(restore(run(channelDeferred, scopeDeferred, child))),
             Effect.flatMap((fiber) =>
               pipe(
-                Effect.addFinalizer(() => Deferred.succeed(scopeDeferred, void 0)),
+                Scope.addFinalizer(
+                  parent,
+                  Deferred.succeed(scopeDeferred, void 0).pipe(
+                    Effect.zipRight(Effect.yieldNow())
+                  )
+                ),
                 Effect.zipRight(restore(Deferred.await(channelDeferred))),
                 Effect.zipLeft(Fiber.inheritAll(fiber))
               )