(self, receiver: Callable[P, Awaitable[None] | None])
| 83 | super().connect(receiver) |
| 84 | |
| 85 | def disconnect(self, receiver: Callable[P, Awaitable[None] | None]) -> None: |
| 86 | super().disconnect(receiver) |
| 87 | |
| 88 | async def send(self, *args: P.args, **kwargs: P.kwargs) -> None: |
| 89 | await asyncio.gather( |
nothing calls this directly
no test coverage detected