auto-sync: 2026-05-19 23:32:57
This commit is contained in:
@@ -104,6 +104,13 @@ class Ticker:
|
|||||||
async def stop(self) -> None:
|
async def stop(self) -> None:
|
||||||
"""停止 tick 循环"""
|
"""停止 tick 循环"""
|
||||||
self._running = False
|
self._running = False
|
||||||
|
# 停止 InboxWatcher
|
||||||
|
if self.inbox_watcher:
|
||||||
|
try:
|
||||||
|
await self.inbox_watcher.stop()
|
||||||
|
logger.info("InboxWatcher stopped")
|
||||||
|
except Exception as e:
|
||||||
|
logger.warning("InboxWatcher stop failed: %s", e)
|
||||||
if self._task:
|
if self._task:
|
||||||
self._task.cancel()
|
self._task.cancel()
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user