Searched refs:wait_closed (Results 1 – 16 of 16) sorted by relevance
59 await writer.wait_closed()70 self.loop.run_until_complete(srv.wait_closed())
89 async def wait_closed(self): member in MyProto188 self.run_loop(proto.wait_closed())191 self.run_loop(server.wait_closed())201 self.run_loop(proto.wait_closed())212 self.run_loop(proto.wait_closed())224 self.run_loop(proto.wait_closed())236 self.run_loop(proto.wait_closed())286 self.run_loop(server.wait_closed())
42 await writer.wait_closed()93 await writer.wait_closed()
582 await client_writer.wait_closed()607 self.loop.run_until_complete(self.server.wait_closed())617 await writer.wait_closed()654 await client_writer.wait_closed()673 self.loop.run_until_complete(self.server.wait_closed())683 await writer.wait_closed()922 self.loop.run_until_complete(wr.wait_closed())934 self.loop.run_until_complete(wr.wait_closed())946 await wr.wait_closed()988 f = wr.wait_closed()
297 self.loop.run_until_complete(srv.wait_closed())306 self.loop.run_until_complete(srv.wait_closed())370 self.loop.run_until_complete(srv.wait_closed())474 async def wait_closed(self): member in SelectorEventLoopUnixSockSendfileTests.MyProto520 self.run_loop(proto.wait_closed())523 self.run_loop(server.wait_closed())
1166 self.loop.run_until_complete(srv.wait_closed())1176 await srv.wait_closed()1988 async def wait_closed(self): member in BaseLoopSockSendfileTests.MyProto2044 self.run_loop(server.wait_closed())2048 self.run_loop(proto.wait_closed())2081 self.run_loop(proto.wait_closed())2093 self.run_loop(proto.wait_closed())
934 async def wait_closed(self): member in ProactorEventLoopUnixSockSendfileTests.MyProto983 self.run_loop(proto.wait_closed())986 self.run_loop(server.wait_closed())
584 await server.wait_closed()
2850 loop.run_until_complete(server.wait_closed())2864 loop.run_until_complete(events.AbstractServer().wait_closed())
37 await writer.wait_closed()281 The method should be used along with the ``wait_closed()`` method::284 await stream.wait_closed()327 .. coroutinemethod:: wait_closed()
1439 The server is closed asynchronously, use the :meth:`wait_closed`1496 .. coroutinemethod:: wait_closed()
192 async def wait_closed(self): member in AbstractServer201 await self.wait_closed()
343 async def wait_closed(self): member in StreamWriter
370 await self.wait_closed()376 async def wait_closed(self): member in Server
325 Implement :meth:`asyncio.StreamWriter.wait_closed` and
686 * The new :meth:`StreamWriter.wait_closed() <asyncio.StreamWriter.wait_closed>`