async def METHOD_NAME(stream, callback):
    try:
        while True:
            line = await stream.read(80)
            if line:
                callback(line)
            else:
                break
    except AttributeError:
        pass