async def METHOD_NAME():
    try:
        line = await asyncio.wait_for(self.reader.readline(), self.timeout)
    except asyncio.TimeoutError:
        raise ConnectionError("Timed out waiting for server")
    if not line:
        raise ConnectionError("Connection closed")
    line = line.decode("utf-8")
    if not line.endswith("\n"):
        raise ConnectionError("Bad message %r" % (line))
    return line