Skip to content

Commit 6980507

Browse files
committed
add awaitable to MessageRecipient definition; remove unneeded cast
1 parent 421cc4e commit 6980507

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

can/notifier.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414

1515
logger = logging.getLogger("can.Notifier")
1616

17-
MessageRecipient = Union[Listener, Callable[[Message], None]]
17+
MessageRecipient = Union[Listener, Callable[[Message], Union[Awaitable[None], None]]]
1818

1919

2020
class Notifier:
@@ -140,7 +140,7 @@ def _on_message_available(self, bus: BusABC) -> None:
140140

141141
def _on_message_received(self, msg: Message) -> None:
142142
for callback in self.listeners:
143-
res = cast(Union[None, Optional[Awaitable[Any]]], callback(msg))
143+
res = callback(msg)
144144
if res is not None and self._loop is not None and asyncio.iscoroutine(res):
145145
# Schedule coroutine
146146
self._loop.create_task(res)

0 commit comments

Comments
 (0)