From eabb6bf2a4537d01b45173d3bffece403cae8379 Mon Sep 17 00:00:00 2001
From: "detail-app[bot]" <180357370+detail-app[bot]@users.noreply.github.com>
Date: Tue, 8 Sep 2026 06:00:30 +0000
Subject: [PATCH] chore: remove dormant reconnectEvent infrastructure in
 inference STT

---
 agents/src/inference/stt.ts | 18 ++++--------------
 1 file changed, 4 insertions(+), 14 deletions(-)

diff --git a/agents/src/inference/stt.ts b/agents/src/inference/stt.ts
index 3430f39a2..ad5fdcdc1 100644
--- a/agents/src/inference/stt.ts
+++ b/agents/src/inference/stt.ts
@@ -17,7 +17,7 @@ import {
   SpeechEventType,
 } from '../stt/index.js';
 import { type APIConnectOptions, DEFAULT_API_CONNECT_OPTIONS } from '../types.js';
-import { type AudioBuffer, Event, Task, cancelAndWait, shortuuid, waitForAbort } from '../utils.js';
+import { type AudioBuffer, Task, cancelAndWait, shortuuid } from '../utils.js';
 import { type VAD, VADEventType, type VADStream } from '../vad.js';
 import { type TimedString, createTimedString } from '../voice/io.js';
 import {
@@ -740,7 +740,6 @@ export class SpeechStream<TModel extends STTModels> extends BaseSpeechStream {
   /** @internal */
   _pendingExtra?: Record<string, unknown>;
   private speechDuration = 0;
-  private reconnectEvent = new Event();
   private stt: STT<TModel>;
   private connOptions: APIConnectOptions;
   private activeWs?: WebSocket;
@@ -1067,28 +1066,19 @@ export class SpeechStream<TModel extends STTModels> extends BaseSpeechStream {
         const vadTask = activeVADStream
           ? Task.from(({ signal }) => processVAD(activeVADStream, ws!, signal), connController)
           : undefined;
-        const waitReconnectTask = Task.from(
-          ({ signal }) => ThrowsPromise.race([this.reconnectEvent.wait(), waitForAbort(signal)]),
-          connController,
-        );
 
         try {
           const taskResults = [sendTask.result, wsListenerTask.result, recvTask.result];
           if (vadTask) taskResults.push(vadTask.result);
 
-          await ThrowsPromise.race([ThrowsPromise.all(taskResults), waitReconnectTask.result]);
-
-          // If reconnect didn't trigger, tasks finished - exit loop
-          if (!waitReconnectTask.done) break;
-
-          // Reconnect triggered - clear event and continue loop
-          this.reconnectEvent.clear();
+          await ThrowsPromise.all(taskResults);
+          break;
         } finally {
           connController.abort();
           this.abortController.signal.removeEventListener('abort', onStreamAbort);
           this.activeWs = undefined;
           vadStream?.close();
-          const tasks = [sendTask, wsListenerTask, recvTask, waitReconnectTask];
+          const tasks = [sendTask, wsListenerTask, recvTask];
           if (vadTask) tasks.push(vadTask);
           await cancelAndWait(tasks, DEFAULT_CANCEL_TIMEOUT);
           resourceCleanup();