From d162482dc6886b6f5888f0df91f4088f686dfdad Mon Sep 17 00:00:00 2001
From: cfdaily <cfdaily@gitee.com>
Date: Sun, 17 May 2026 06:12:59 +0800
Subject: [PATCH] auto-sync: 2026-05-17 06:12:59

---
 src/daemon/sse.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/daemon/sse.py b/src/daemon/sse.py
index d7cf626..d3f960b 100644
--- a/src/daemon/sse.py
+++ b/src/daemon/sse.py
@@ -71,7 +71,7 @@ class SSEBroker:
             (client_id, queue)
         """
         cid = client_id or str(uuid.uuid4())
-        queue: asyncio.Queue = asyncio.Queue(maxsize=100)
+        queue = asyncio.Queue(maxsize=100)
         self._subscribers[cid] = queue
 
         # 发送历史事件
@@ -83,6 +83,10 @@ class SSEBroker:
 
         return cid, queue
 
+    async def subscribe_async(self, client_id: Optional[str] = None) -> tuple:
+        """异步订阅（在 async 上下文中调用）"""
+        return self.subscribe(client_id)
+
     def unsubscribe(self, client_id: str) -> None:
         if client_id in self._subscribers:
             del self._subscribers[client_id]