Refactor Claude stream error handling

- Consolidate Claude stream exit handling through `Exit.match`
- Preserve interrupted vs failed turn completion and runtime error emission

Author: juliusmarminge

apps/server/src/provider/Layers/ClaudeAdapter.ts

@@ -1302,6 +1302,29 @@ const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
     });
   });
 
+  const handleClaudeStreamError = (
+    context: ClaudeSessionContext,
+    cause: Cause.Cause<ClaudeStreamError>,
+  ) =>
+    Option.match(Cause.findErrorOption(cause), {
+      onNone: () =>
+        context.turnState
+          ? completeTurn(context, "failed", "Claude runtime stream failed.")
+          : Effect.void,
+      onSome: (streamError) =>
+        isClaudeStreamInterruptedError(streamError)
+          ? context.turnState
+            ? completeTurn(context, "interrupted", "Claude runtime interrupted.")
+            : Effect.void
+          : Effect.gen(function* () {
+              const message = streamError.message;
+              yield* emitRuntimeError(context, message, Cause.pretty(cause));
+              if (context.turnState) {
+                yield* completeTurn(context, "failed", message);
+              }
+            }),
+    });
+
   const completeTurn = Effect.fn("completeTurn")(function* (
     context: ClaudeSessionContext,
     status: ProviderRuntimeTurnStatus,
@@ -2228,34 +2251,16 @@ const makeClaudeAdapter = Effect.fn("makeClaudeAdapter")(function* (
       return;
     }
 
-    if (Exit.isFailure(exit)) {
-      if (Cause.hasInterruptsOnly(exit.cause)) {
-        if (context.turnState) {
-          yield* completeTurn(context, "interrupted", "Claude runtime interrupted.");
-        }
-      } else {
-        yield* Option.match(Cause.findErrorOption(exit.cause), {
-          onNone: () =>
-            context.turnState
-              ? completeTurn(context, "failed", "Claude runtime stream failed.")
-              : Effect.void,
-          onSome: (streamError) =>
-            isClaudeStreamInterruptedError(streamError)
-              ? context.turnState
-                ? completeTurn(context, "interrupted", "Claude runtime interrupted.")
-                : Effect.void
-              : Effect.gen(function* () {
-                  const message = streamError.message;
-                  yield* emitRuntimeError(context, message, Cause.pretty(exit.cause));
-                  if (context.turnState) {
-                    yield* completeTurn(context, "failed", message);
-                  }
-                }),
-        });
-      }
-    } else if (context.turnState) {
-      yield* completeTurn(context, "interrupted", "Claude runtime stream ended.");
-    }
+    yield* Exit.match(exit, {
+      onSuccess: () =>
+        context.turnState
+          ? completeTurn(context, "interrupted", "Claude runtime stream ended.")
+          : Effect.void,
+      onFailure: (cause) =>
+        Cause.hasInterruptsOnly(cause) && context.turnState
+          ? completeTurn(context, "interrupted", "Claude runtime interrupted.")
+          : handleClaudeStreamError(context, cause),
+    });
 
     yield* stopSessionInternal(context, {
       emitExitEvent: true,