refresh timeout if not done

livekit · Sep 18, 2024 · cc63478 · cc63478
1 parent 99abc28
commit cc63478
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/packages/livekit-rtc/src/audio_source.ts b/packages/livekit-rtc/src/audio_source.ts
@@ -30,6 +30,8 @@ export class AudioSource {
   currentQueueSize: number;
   /** @internal */
   releaseQueue = new Queue<void>();
+  /** @internal */
+  timeout?: ReturnType<typeof setTimeout> = undefined;
 
   sampleRate: number;
   numChannels: number;
@@ -96,6 +98,9 @@ export class AudioSource {
     this.currentQueueSize -= 0.05
     this.lastCapture = now
 
+    if (this.timeout) {
+      clearTimeout(this.timeout);
+    }
     setTimeout(this.releaseQueue.put, this.currentQueueSize)
 
     const req = new CaptureAudioFrameRequest({