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())
84 async def wait_closed(self): member in MyProto183 self.run_loop(proto.wait_closed())186 self.run_loop(server.wait_closed())196 self.run_loop(proto.wait_closed())207 self.run_loop(proto.wait_closed())219 self.run_loop(proto.wait_closed())231 self.run_loop(proto.wait_closed())281 self.run_loop(server.wait_closed())
42 await writer.wait_closed()94 await writer.wait_closed()
595 await client_writer.wait_closed()622 self.loop.run_until_complete(self.server.wait_closed())634 await writer.wait_closed()673 await client_writer.wait_closed()694 self.loop.run_until_complete(self.server.wait_closed())706 await writer.wait_closed()914 self.loop.run_until_complete(wr.wait_closed())927 self.loop.run_until_complete(wr.wait_closed())939 await wr.wait_closed()983 f = wr.wait_closed()
1157 self.loop.run_until_complete(srv.wait_closed())1169 await srv.wait_closed()1979 async def wait_closed(self): member in BaseLoopSockSendfileTests.MyProto2035 self.run_loop(server.wait_closed())2039 self.run_loop(proto.wait_closed())2072 self.run_loop(proto.wait_closed())2084 self.run_loop(proto.wait_closed())
288 self.loop.run_until_complete(srv.wait_closed())297 self.loop.run_until_complete(srv.wait_closed())361 self.loop.run_until_complete(srv.wait_closed())465 async def wait_closed(self): member in SelectorEventLoopUnixSockSendfileTests.MyProto511 self.run_loop(proto.wait_closed())514 self.run_loop(server.wait_closed())
918 async def wait_closed(self): member in ProactorEventLoopUnixSockSendfileTests.MyProto967 self.run_loop(proto.wait_closed())970 self.run_loop(server.wait_closed())
582 await server.wait_closed()
2770 loop.run_until_complete(server.wait_closed())2784 loop.run_until_complete(events.AbstractServer().wait_closed())
37 await writer.wait_closed()259 The method should be used along with the ``wait_closed()`` method::262 await stream.wait_closed()305 .. coroutinemethod:: wait_closed()
1421 The server is closed asynchronously, use the :meth:`wait_closed`1478 .. coroutinemethod:: wait_closed()
192 async def wait_closed(self): member in AbstractServer201 await self.wait_closed()
358 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
685 * The new :meth:`StreamWriter.wait_closed() <asyncio.StreamWriter.wait_closed>`