From d323ea9e95960b17f8a541cbd616bd4272de1caa Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= <aleix@daily.co>
Date: Thu, 26 Sep 2024 16:44:49 -0700
Subject: [PATCH] async_generator: keep pushing frames downstream

---
 src/pipecat/processors/async_generator.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/pipecat/processors/async_generator.py b/src/pipecat/processors/async_generator.py
index 66b2a3e99..4f9bc85d0 100644
--- a/src/pipecat/processors/async_generator.py
+++ b/src/pipecat/processors/async_generator.py
@@ -26,6 +26,8 @@ class AsyncGeneratorProcessor(FrameProcessor):
     async def process_frame(self, frame: Frame, direction: FrameDirection):
         await super().process_frame(frame, direction)
 
+        await self.push_frame(frame, direction)
+
         if isinstance(frame, (CancelFrame, EndFrame)):
             await self._data_queue.put(None)
         else: