def METHOD_NAME(source, dst):
    is_connected = True
    logging.warning(f"streaming {source.name} to {dst.name}")
    for line in iter(source.readline, b""):
        if is_connected:
            try:
                dst.write(line.decode("utf-8"))
                dst.flush()
                logging.warning(f"{dst.name}: {line}")
            except Exception as e:
                logging.warning(f"failed writing to {dst}: {e}")
                logging.warning(f"{dst.name}: {line}")
                is_connected = False
        else:
            logging.warning(f"{dst.name}: {line}")
            is_connected = False