Update app.py

app.py

@@ -90,7 +90,7 @@ class GeminiHandler(AsyncAudioVideoStreamHandler):
         self.video_queue.put_nowait(frame)
 
     async def video_emit(self):
-        frame = await wait_for_item(self.video_queue)
+        frame = await self.video_queue.get()
         if frame is not None:
             return frame
         else:
@@ -104,9 +104,7 @@ class GeminiHandler(AsyncAudioVideoStreamHandler):
             await self.session.send(input=audio_message)
 
     async def emit(self):
-        array = await wait_for_item(self.audio_queue)
-        if array is not None:
-            return (self.output_sample_rate, array)
+        return await self.audio_queue.get()
 
     async def shutdown(self) -> None:
         if self.session: