fix(embedded-agent-runner): remove unused wrapRetryStreamWithRecoveryNotification

lzyyzznl · lzyyzznl · commit 18b872365995 · 2026-06-22T22:56:15.000+08:00
The function was replaced by pumpStreamWithRecovery + retryStreamWithoutThinking
in the async stream refactor but the old wrapper was left as dead code.
diff --git a/src/agents/embedded-agent-runner/thinking.ts b/src/agents/embedded-agent-runner/thinking.ts
@@ -602,34 +602,6 @@ function isSuccessfulRecoveryRetryResult(message: AssistantMessage | undefined):
   return message.stopReason !== "error" && message.stopReason !== "aborted";
 }
 
-function wrapRetryStreamWithRecoveryNotification(
-  retryStream: ReturnType<StreamFn>,
-  notify: () => Promise<void>,
-): ReturnType<StreamFn> {
-  if (retryStream instanceof Promise) {
-    return retryStream.then((resolved) =>
-      wrapRetryStreamWithRecoveryNotification(resolved as ReturnType<StreamFn>, notify),
-    ) as ReturnType<StreamFn>;
-  }
-  const streamWithResult = retryStream as unknown as {
-    result?: () => Promise<AssistantMessage>;
-  };
-  if (typeof streamWithResult.result !== "function") {
-    return retryStream;
-  }
-  const result = streamWithResult.result.bind(streamWithResult);
-  let notified = false;
-  streamWithResult.result = async () => {
-    const message = await result();
-    if (!notified && isSuccessfulRecoveryRetryResult(message)) {
-      notified = true;
-      await notify();
-    }
-    return message;
-  };
-  return retryStream;
-}
-
 async function retryStreamWithoutThinking(
   outer: ReturnType<typeof createAssistantMessageEventStream>,
   retry: () => ReturnType<StreamFn>,
