fz-mirrors/AstrBot
1
0
Fork 0
mirror of https://github.com/AstrBotDevs/AstrBot synced 2026-07-19 18:47:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

perf: non block

Browse Source
This commit is contained in:
Soulter
2025-11-11 19:55:56 +08:00
parent 70dbe2a567
commit 8b34403587
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/astrbot_sdk/runtime/rpc/server/stdio.py
View File

@@ -110,7 +110,7 @@ class StdioServer(JSONRPCServer):
try:
# Parse JSON-RPC message
message = self._parse_message(line)
await self._handle_message(message)
asyncio.create_task(self._handle_message(message))
except Exception as e:
logger.error(f"Failed to parse message: {e}, raw line: {line}")

4
src/astrbot_sdk/runtime/rpc/server/websockets.py
View File

@@ -125,7 +125,7 @@ class WebSocketServer(JSONRPCServer):
if msg.type == aiohttp.WSMsgType.TEXT:
try:
message = self._parse_message(msg.data)
await self._handle_message(message)
asyncio.create_task(self._handle_message(message))
except Exception as e:
logger.error(f"Failed to parse message: {e}, raw data: {msg.data}")
@@ -133,7 +133,7 @@ class WebSocketServer(JSONRPCServer):
try:
text = msg.data.decode("utf-8")
message = self._parse_message(text)
await self._handle_message(message)
asyncio.create_task(self._handle_message(message))
except Exception as e:
logger.error(f"Failed to parse binary message: {e}")