ensure Channel executor catches defects in doneHalt (#4430)

Author: tim-smart

.changeset/neat-ducks-visit.md

@@ -0,0 +1,5 @@
+---
+"effect": patch
+---
+
+ensure Channel executor catches defects in doneHalt

packages/effect/src/internal/channel.ts

@@ -1855,9 +1855,15 @@ export const orDieWith = dual<
   self: Channel.Channel<OutElem, InElem, OutErr, InErr, OutDone, InDone, Env>,
   f: (e: OutErr) => unknown
 ): Channel.Channel<OutElem, InElem, never, InErr, OutDone, InDone, Env> =>
-  catchAll(self, (e) => {
-    throw f(e)
-  }) as Channel.Channel<OutElem, InElem, never, InErr, OutDone, InDone, Env>)
+  catchAll(self, (e) => core.failCauseSync(() => Cause.die(f(e)))) as Channel.Channel<
+    OutElem,
+    InElem,
+    never,
+    InErr,
+    OutDone,
+    InDone,
+    Env
+  >)
 
 /** @internal */
 export const orElse = dual<

packages/effect/src/internal/channel/channelExecutor.ts

@@ -503,7 +503,11 @@ export class ChannelExecutor<
     const head = this._doneStack[this._doneStack.length - 1] as Continuation.Primitive
     if (head._tag === ContinuationOpCodes.OP_CONTINUATION_K) {
       this._doneStack.pop()
-      this._currentChannel = head.onHalt(cause) as core.Primitive
+      try {
+        this._currentChannel = head.onHalt(cause) as core.Primitive
+      } catch (error) {
+        this._currentChannel = core.failCause(Cause.die(error)) as core.Primitive
+      }
       return undefined
     }