Skip to content

Commit 23a5276

Browse files
update generic type params
1 parent 3de5999 commit 23a5276

1 file changed

Lines changed: 6 additions & 4 deletions

File tree

i3ipc/aio/connection.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -36,10 +36,12 @@ def ensure_future(obj):
3636
_BaseEvent = TypeVar('_BaseEvent', bound=IpcBaseEvent, contravariant=True)
3737

3838

39-
Handler: TypeAlias = Union[
40-
Callable[['Connection', _BaseEvent], None], Callable[['Connection', _BaseEvent], Coroutine]
39+
_Handler: TypeAlias = Union[
40+
Callable[['Connection', _BaseEvent], None], Callable[['Connection', _BaseEvent], Coroutine[None, None, None]]
4141
]
4242

43+
Handler: TypeAlias = _Handler[IpcBaseEvent]
44+
4345

4446
class _Subscription(TypedDict):
4547
event: str
@@ -530,8 +532,8 @@ async def subscribe(self, events: Union[list[Event], list[str]], force: bool = F
530532

531533
await self._loop.sock_sendall(self._sub_socket, _pack(MessageType.SUBSCRIBE, payload))
532534

533-
def on(self, event: Union[Event, str], handler: Optional[Handler] = None):
534-
def on_wrapped(handler):
535+
def on(self, event: Union[Event, str], handler: Optional[Handler] = None) ->Handler|Callable[[Handler], Handler]:
536+
def on_wrapped(handler: Handler) -> Handler:
535537
self._on(event, handler)
536538
return handler
537539

0 commit comments

Comments
 (0)