Lines Matching refs:async
40 async def _establish_session(self):
44 async def _do_start_server(self, address, ssl=None):
52 async def _do_accept(self):
58 async def _do_connect(self, address, ssl=None):
65 async def _do_recv(self) -> None:
72 async def send_msg(self) -> None:
75 async def simulate_disconnect(self) -> None:
99 async def _do_recv(self) -> str:
109 async def send_msg(self, msg: str) -> None:
120 async def _runner():
218 async def _asyncSetUp(self):
221 async def _asyncTearDown(self):
230 async def _wrapper(self, *args, **kwargs):
259 async def _watch_runstates(self, *states):
265 async def _watcher():
282 async def testSuperfluousDisconnect(self):
297 async def _bad_connection(self, family: str):
305 async def _hanging_connection(self):
309 async def _bad_connection_test(self, family: str):
322 async def testBadINET(self):
329 async def testBadUNIX(self):
336 async def testCancellation(self):
357 async def testTimeout(self):
377 async def testRequire(self):
401 async def testImplicitRunstateInit(self):
425 async def _bad_connection(self, family: str):
433 async def _hanging_connection(self):
445 async def _asyncSetUp(self):
449 async def _asyncTearDown(self):
456 async def testFakeConnect(self):
463 async def testFakeAccept(self):
469 async def testFakeRecv(self):
485 async def testFakeSend(self):
501 async def _prod_session_api(
518 async def testAcceptRequireRunning(self):
529 async def testConnectRequireRunning(self):
540 async def testAcceptRequireDisconnecting(self):
555 async def testConnectRequireDisconnecting(self):
576 async def _asyncSetUp(self):
580 async def _asyncTearDown(self):
589 async def testSmoke(self):