revert: 回退 commit 94e34c9370

src/chat/chatter_manager.py

@@ -207,12 +207,11 @@ class ChatterManager:
 
         return active_tasks
 
-    def cancel_all_stream_tasks(self, stream_id: str, exclude_reply: bool = False) -> int:
+    def cancel_all_stream_tasks(self, stream_id: str) -> int:
         """取消指定流的所有处理任务（包括多重回复）
 
         Args:
             stream_id: 流ID
-            exclude_reply: 是否排除回复任务
 
         Returns:
             int: 成功取消的任务数量
@@ -222,15 +221,10 @@ class ChatterManager:
 
         tasks = self._processing_tasks[stream_id]
         cancelled_count = 0
-        remaining_tasks = []
 
-        logger.info(f"开始取消流 {stream_id} 的处理任务，共 {len(tasks)} 个")
+        logger.info(f"开始取消流 {stream_id} 的所有处理任务，共 {len(tasks)} 个")
 
         for task in tasks:
-            if exclude_reply and "reply" in task.get_name().lower():
-                remaining_tasks.append(task)
-                continue
-
             try:
                 if not task.done():
                     task.cancel()
@@ -239,12 +233,8 @@ class ChatterManager:
             except Exception as e:
                 logger.warning(f"取消任务时出错: {e}")
 
-        if remaining_tasks:
-            self._processing_tasks[stream_id] = remaining_tasks
-        else:
-            if stream_id in self._processing_tasks:
-                del self._processing_tasks[stream_id]
-
+        # 清理任务记录
+        del self._processing_tasks[stream_id]
         logger.info(f"流 {stream_id} 的任务取消完成，成功取消 {cancelled_count} 个任务")
         return cancelled_count