Searched refs:wait_closed (Results 1 – 15 of 15) sorted by relevance
55 await writer.wait_closed()66 self.loop.run_until_complete(srv.wait_closed())
39 await writer.wait_closed()90 await writer.wait_closed()
607 self.loop.run_until_complete(self.server.wait_closed())671 self.loop.run_until_complete(self.server.wait_closed())878 self.loop.run_until_complete(wr.wait_closed())890 self.loop.run_until_complete(wr.wait_closed())
1142 self.loop.run_until_complete(srv.wait_closed())1153 await srv.wait_closed()1904 async def wait_closed(self): member in BaseLoopSockSendfileTests.MyProto1960 self.run_loop(server.wait_closed())1964 self.run_loop(proto.wait_closed())1997 self.run_loop(proto.wait_closed())2009 self.run_loop(proto.wait_closed())
273 self.loop.run_until_complete(srv.wait_closed())282 self.loop.run_until_complete(srv.wait_closed())346 self.loop.run_until_complete(srv.wait_closed())450 async def wait_closed(self): member in SelectorEventLoopUnixSockSendfileTests.MyProto496 self.run_loop(proto.wait_closed())499 self.run_loop(server.wait_closed())
2167 async def wait_closed(self): member in SockSendfileMixin.MyProto2221 self.run_loop(proto.wait_closed())2224 self.run_loop(server.wait_closed())2234 self.run_loop(proto.wait_closed())2245 self.run_loop(proto.wait_closed())2257 self.run_loop(proto.wait_closed())2269 self.run_loop(proto.wait_closed())2333 self.run_loop(server.wait_closed())3333 loop.run_until_complete(server.wait_closed())3347 loop.run_until_complete(events.AbstractServer().wait_closed())
889 async def wait_closed(self): member in ProactorEventLoopUnixSockSendfileTests.MyProto938 self.run_loop(proto.wait_closed())941 self.run_loop(server.wait_closed())
505 await server.wait_closed()
198 async def wait_closed(self): member in AbstractServer207 await self.wait_closed()
322 async def wait_closed(self): member in StreamWriter
344 await self.wait_closed()350 async def wait_closed(self): member in Server
32 await writer.wait_closed()289 .. coroutinemethod:: wait_closed()
1328 The server is closed asynchronously, use the :meth:`wait_closed`1385 .. coroutinemethod:: wait_closed()
326 Implement :meth:`asyncio.StreamWriter.wait_closed` and
680 * The new :meth:`StreamWriter.wait_closed() <asyncio.StreamWriter.wait_closed>`