Explicitly close AudioResampler instances too free up resources

Author: lukasIO

agents/src/inference/interruption/interruption_stream.ts

@@ -414,6 +414,7 @@ export class InterruptionStreamBase {
 
   async close(): Promise<void> {
     if (!this.inputStream.closed) await this.inputStream.close();
+    this.resampler?.close();
     this.model.removeStream(this);
   }
 }

agents/src/stt/stt.ts

@@ -445,6 +445,7 @@ export abstract class SpeechStream implements AsyncIterableIterator<SpeechEvent>
     if (!this.queue.closed) this.queue.close();
     if (!this.output.closed) this.output.close();
     if (!this.abortController.signal.aborted) this.abortController.abort();
+    this.resampler?.close();
     this.closed = true;
   }
 

agents/src/tts/fallback_adapter.ts

@@ -366,6 +366,7 @@ class FallbackChunkedStream extends ChunkedStream {
             });
             audioReceived = true;
           }
+          resampler.close();
         }
 
         // Verify audio was actually received - silent failures should trigger fallback
@@ -519,6 +520,7 @@ class FallbackSynthesizeStream extends SynthesizeStream {
                 });
                 this.audioPushed = true;
               }
+              resampler.close();
             }
           } finally {
             // processOutput and forwardBufferToTTS run in parallel.

agents/src/utils.ts

@@ -723,6 +723,7 @@ export function resampleStream({
         for (const frame of resampler.flush()) {
           controller.enqueue(frame);
         }
+        resampler.close();
       }
     },
   });

agents/src/voice/generation.ts

@@ -839,6 +839,7 @@ async function forwardAudio(
       for (const f of resampler.flush()) {
         await audioOutput.captureFrame(f);
       }
+      resampler.close();
     }
   } catch (e) {
     if (e instanceof IdleTimeoutError) {

agents/src/voice/recorder_io/recorder_io.ts

@@ -352,6 +352,8 @@ export class RecorderIO {
     } finally {
       inReader.releaseLock();
       outReader.releaseLock();
+      this.inResampler?.close();
+      this.outResampler?.close();
 
       if (!this.closeFuture.done) {
         this.closeFuture.resolve();

plugins/google/src/beta/realtime/realtime_api.ts

@@ -810,6 +810,7 @@ export class RealtimeSession extends llm.RealtimeSession {
     this.#closed = true;
 
     this.sessionShouldClose.set();
+    this.inputResampler?.close();
 
     await this.closeActiveSession();
 
@@ -1660,6 +1661,7 @@ export class RealtimeSession extends llm.RealtimeSession {
     if (this.inputResampler) {
       if (frame.sampleRate !== this.inputResamplerInputRate) {
         // input audio changed to a different sample rate
+        this.inputResampler.close();
         this.inputResampler = undefined;
         this.inputResamplerInputRate = undefined;
       }

plugins/phonic/src/realtime/realtime_model.ts

@@ -440,6 +440,7 @@ export class RealtimeSession extends llm.RealtimeSession {
     this.instructionsReady.resolve();
     this.toolsReady.resolve();
     this.closeCurrentGeneration({ interrupted: false });
+    this.inputResampler?.close();
     this.socket?.close();
     await this.connectTask;
     await super.close();
@@ -748,6 +749,7 @@ export class RealtimeSession extends llm.RealtimeSession {
   private *resampleAudio(frame: AudioFrame): Generator<AudioFrame> {
     if (this.inputResampler) {
       if (frame.sampleRate !== this.inputResamplerInputRate) {
+        this.inputResampler.close();
         this.inputResampler = undefined;
         this.inputResamplerInputRate = undefined;
       }

plugins/silero/src/vad.ts

@@ -388,6 +388,7 @@ export class VADStream extends baseStream {
           }
         }
       }
+      resampler?.close();
     });
   }
 

plugins/test/src/stt.ts

@@ -130,6 +130,7 @@ const makeTestSpeech = (targetSampleRate: number, chunkDuration?: number): Audio
       output.push(...resampler.push(frame));
     }
     output.push(...resampler.flush());
+    resampler.close();
     frames = output;
   }