added streaming output capability to the frontend.

Author: JDOxygen

CHANGELOG.md

@@ -7,6 +7,17 @@ All notable changes to this project will be documented in this file.
 ### Added
 - Added support for dynamic registration of `oxy`
 
+---
+
+## [1.0.8] - 2025-11-14
+
+### Added
+- Added streaming output capability to the frontend
+- Added Agent name field to think messages
+
+### Changed
+- LChanged the default value of the LLM parameter stream to True
+
 ---
 ## [1.0.6.3] - 2025-10-15
 

CHANGELOG_zh.md

@@ -9,6 +9,17 @@
 
 ---
 
+## [1.0.8] - 2025-11-14
+
+### Added
+- 新增前端的流式输出能力
+
+### Changed
+- LLM参数 stream 默认值修改为 True
+- think消息 增加 Agent 名称字段
+
+---
+
 ## [1.0.6.3] - 2025-10-15
 
 ### Added

demo.py

@@ -12,7 +12,6 @@
         api_key=os.getenv("DEFAULT_LLM_API_KEY"),
         base_url=os.getenv("DEFAULT_LLM_BASE_URL"),
         model_name=os.getenv("DEFAULT_LLM_MODEL_NAME"),
-        # llm_params={"stream": True},  # 开启流式输出
     ),
     preset_tools.time_tools,
     oxy.ReActAgent(
@@ -36,7 +35,6 @@
         is_master=True,
         name="master_agent",
         sub_agents=["time_agent", "file_agent", "math_agent"],
-        # team_size=2, # 开启团队协作，每个agent会调用2次llm
     ),
 ]
 

oxygent/oxy/llms/base_llm.py

@@ -217,7 +217,9 @@ async def _post_send_message(self, oxy_response: OxyResponse):
                     tool_call_dict = json.loads(extract_first_json(oxy_response.output))
                     if "think" in tool_call_dict:
                         msg = tool_call_dict["think"].strip()
-                await oxy_request.send_message({"type": "think", "content": msg})
+                await oxy_request.send_message(
+                    {"type": "think", "content": msg, "agent": oxy_request.caller}
+                )
             except json.JSONDecodeError:
                 pass
             except Exception as e:

oxygent/oxy/llms/http_llm.py

@@ -92,7 +92,7 @@ async def _execute(self, oxy_request: OxyRequest) -> OxyResponse:
             payload = {
                 "messages": await self._get_messages(oxy_request),
                 "model": self.model_name,
-                "stream": False,
+                "stream": True,
             }
             payload.update(llm_config)
             for k, v in self.llm_params.items():

oxygent/oxy/llms/openai_llm.py

@@ -53,7 +53,7 @@ async def _execute(self, oxy_request: OxyRequest) -> OxyResponse:
         payload = {
             "messages": await self._get_messages(oxy_request),
             "model": self.model_name,
-            "stream": False,
+            "stream": True,
         }
         payload.update(llm_config)
         for k, v in self.llm_params.items():