fix tests

Author: toubatbrian

agents/src/voice/agent_activity.ts

@@ -459,7 +459,9 @@ export class AgentActivity implements RecognitionHooks {
     const hasSttOld = !!this.stt;
     const hasSttNew = !!newActivity.stt;
     const sameSttInstance = this.stt === newActivity.stt;
-    const sameSttNode = Object.getPrototypeOf(this.agent).sttNode === Object.getPrototypeOf(newActivity.agent).sttNode;
+    const sameSttNode =
+      Object.getPrototypeOf(this.agent).sttNode ===
+      Object.getPrototypeOf(newActivity.agent).sttNode;
 
     if (!hasAudioRecognition || !hasSttOld || !hasSttNew) {
       return undefined;

agents/src/voice/audio_recognition.ts

@@ -96,11 +96,15 @@ export class STTPipeline {
     const node = await this.sttNode(this._audioChannel.stream(), {});
     if (node === null) return;
 
-    for await (const value of readStream(node, signal)) {
-      if (typeof value === 'string') {
-        throw new Error(`STT node must yield SpeechEvent, got: ${typeof value}`);
+    try {
+      for await (const value of readStream(node, signal)) {
+        if (typeof value === 'string') {
+          throw new Error(`STT node must yield SpeechEvent, got: ${typeof value}`);
+        }
+        await this._eventChannel.write(value);
       }
-      await this._eventChannel.write(value);
+    } finally {
+      await node.cancel().catch(() => {});
     }
   }
 

agents/src/voice/audio_recognition_handoff.test.ts

@@ -6,7 +6,7 @@ import { describe, expect, it, vi } from 'vitest';
 import { ChatContext } from '../llm/chat_context.js';
 import { initializeLogger } from '../log.js';
 import { type SpeechEvent, SpeechEventType } from '../stt/stt.js';
-import { AudioRecognition, STTPipeline, type RecognitionHooks } from './audio_recognition.js';
+import { AudioRecognition, type RecognitionHooks, STTPipeline } from './audio_recognition.js';
 import type { STTNode } from './io.js';
 
 function createHooks() {