Method run_test

Lib/test/test_asyncio/test_streams.py:850–857

()

            await writer.wait_closed()

        async def run_test():
            server = await asyncio.start_server(
                server_handler, socket_helper.HOSTv4, 0)
            server_addr = server.sockets[0].getsockname()

            await client(server_addr)
            server.close()
            await server.wait_closed()

        messages = []
        self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))