Keep text-delta suppression across non-fatal reactor errors

Author: TheGreatAxios

src/tui/stream-event-map.test.ts

@@ -144,6 +144,29 @@ describe("mapProductionEvent", () => {
     ).toEqual([]);
   });
 
+  test("non-fatal reactor.error keeps connector.reply suppression after deltas", () => {
+    const ctx = createStreamMapContext();
+    mapProductionEvent(
+      { type: "inference.text.delta", data: { token: "partial" } },
+      ctx,
+    );
+    expect(
+      mapProductionEvent(
+        {
+          type: "reactor.error",
+          data: { error: "transient checkpoint write", fatal: false },
+        },
+        ctx,
+      ),
+    ).toEqual([{ type: "error", message: "transient checkpoint write" }]);
+    expect(
+      mapProductionEvent(
+        { type: "connector.reply", data: { content: "final answer" } },
+        ctx,
+      ),
+    ).toEqual([]);
+  });
+
   test("connector.reply without prior deltas becomes assistant", () => {
     expect(
       mapProductionEvent({

src/tui/stream-event-map.ts

@@ -575,10 +575,12 @@ function mapEvent(
     case "reactor.error": {
       const error =
         typeof data.error === "string" ? data.error : "reactor error";
-      if (ctx) ctx.hadTextDelta = false;
+      // Non-fatal errors don't end the turn: keep delta suppression so a
+      // later connector.reply doesn't repaint already-streamed text.
       if (!isReactorErrorFatal(event.data)) {
         return [{ type: "error", message: error }];
       }
+      if (ctx) ctx.hadTextDelta = false;
       return [
         ...disarmAttempt(ctx),
         { type: "error", message: error },