Skip to content

Commit 2f3b7d4

Browse files
authored
Fix Mailbox.fromStream (#4837)
1 parent 4be592b commit 2f3b7d4

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

.changeset/twenty-doors-glow.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
"effect": patch
3+
---
4+
5+
fix Mailbox.fromStream

packages/effect/src/internal/mailbox.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -547,7 +547,7 @@ export const fromStream: {
547547
onFailure: (cause: Cause<E>) => mailbox.failCause(cause),
548548
onDone: () => mailbox.end
549549
})
550-
return channel.unwrapScopedWith((scope) =>
550+
return fiberRuntime.scopeWith((scope) =>
551551
stream.toChannel(self).pipe(
552552
coreChannel.pipeTo(writer),
553553
channelExecutor.runIn(scope),

0 commit comments

Comments
 (0)