fix: event_bus类型注解
This commit is contained in:
@@ -9,7 +9,7 @@
|
|||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
import contextlib
|
import contextlib
|
||||||
from typing import Any, Awaitable, Callable, Dict, List, Optional, Tuple
|
from typing import Any, Callable, Dict, List, Optional, Tuple, Coroutine
|
||||||
|
|
||||||
from src.common.logger import get_logger
|
from src.common.logger import get_logger
|
||||||
from src.core.types import EventType, MaiMessages
|
from src.core.types import EventType, MaiMessages
|
||||||
@@ -17,7 +17,7 @@ from src.core.types import EventType, MaiMessages
|
|||||||
logger = get_logger("event_bus")
|
logger = get_logger("event_bus")
|
||||||
|
|
||||||
# Handler 签名:接收 MaiMessages,返回 (continue, modified_message)
|
# Handler 签名:接收 MaiMessages,返回 (continue, modified_message)
|
||||||
EventHandler = Callable[[Optional[MaiMessages]], Awaitable[Tuple[bool, Optional[MaiMessages]]]]
|
EventHandler = Callable[[Optional[MaiMessages]], Coroutine[Any, Any, Tuple[bool, Optional[MaiMessages]]]]
|
||||||
|
|
||||||
|
|
||||||
class EventBus:
|
class EventBus:
|
||||||
|
|||||||
Reference in New Issue
Block a user