async queue pipeline

asr.py

@@ -194,7 +194,7 @@ class ASRPipeline:
             return None
 
         text = self.groq_transcribe(self.rolling_buffer.copy())
-        self.rolling_buffer = np.array([], dtype=np.float32)
+        self.rolling_buffer = self.rolling_buffer[BUFFER_SAMPLES//2:]
 
         if not text:
             return None