Lines Matching refs:async
263 async def runstate_changed(self) -> Runstate:
272 async def start_server_and_accept(
302 async def start_server(self, address: SocketAddrT,
331 async def accept(self) -> None:
359 async def connect(self, address: Union[SocketAddrT, socket.socket],
388 async def disconnect(self) -> None:
405 async def _session_guard(self, coro: Awaitable[None], emsg: str) -> None:
488 async def _stop_server(self) -> None:
503 async def _incoming(self,
535 async def _do_start_server(self, address: SocketAddrT,
586 async def _do_accept(self) -> None:
603 async def _do_connect(self, address: Union[SocketAddrT, socket.socket],
651 async def _establish_session(self) -> None:
695 async def _wait_disconnect(self) -> None:
753 async def _bh_disconnect(self) -> None:
812 async def _bh_flush_writer(self) -> None:
823 async def _bh_close_stream(self, error_pathway: bool = False) -> None:
858 async def _bh_loop_forever(self, async_fn: _TaskFN, name: str) -> None:
889 async def _bh_send_message(self) -> None:
902 async def _bh_recv_message(self) -> None:
954 async def _readline(self) -> bytes:
983 async def _do_recv(self) -> T:
993 async def _recv(self) -> T:
1024 async def _send(self, msg: T) -> None:
1044 async def _on_message(self, msg: T) -> None: