Merge main into sweep/fix-asyncio-event-loop-error

packages/core/src/chat_engine/types.py

@@ -0,0 +1,12 @@
+import asyncio
+
+class StreamingAgentChatResponse:
+    def __init__(self):
+        self._aqueue: asyncio.Queue = asyncio.Queue()
+
+    async def put(self, item):
+        await self._aqueue.put(item)
+
+    async def get(self):
+        return await self._aqueue.get()
+