async def METHOD_NAME(self, number_of_lines, timeout):
    lines = []
    for i in range(number_of_lines):
        try:
            line = await asyncio.wait_for(self._stream.readline(), timeout=timeout)
        except (asyncio.TimeoutError) as err:
            raise Exception("Could not read {} number of lines. Connection closed after {} lines".format(number_of_lines, len(lines))) from err
        lines.append(line.decode("utf-8"))
    return lines