(self)
| 632 | await client_writer.wait_closed() |
| 633 | |
| 634 | def start(self): |
| 635 | sock = socket.create_server(('127.0.0.1', 0)) |
| 636 | self.server = self.loop.run_until_complete( |
| 637 | asyncio.start_server(self.handle_client, |
| 638 | sock=sock)) |
| 639 | return sock.getsockname() |
| 640 | |
| 641 | def handle_client_callback(self, client_reader, client_writer): |
| 642 | self.loop.create_task(self.handle_client(client_reader, |
no test coverage detected