Disconnection from ligier causes infinite loop

Minimal working example:

from km3pipe import Pipeline, Module, logger
from km3pipe.io.ch import CHPump
from km3modules import Dump

def main():
    
    pipe = Pipeline()
    pipe.attach(
        CHPump,
        host='localhost',
        port=5555,
        tags='TEST',
    )
    pipe.attach(Dump, full=True)
    pipe.drain()


if __name__ == '__main__':
    main()

• Setup a controlhost server (I use podman run --expose 5555 -p 5555:5555 docker.km3net.de/jpp:latest JLigier -P 5555)
• Run the program above
• Send a message (Use podman run docker.km3net.de/jpp:latest JPutMessage -H "elastic_lewin:5555" -t "TEST" -m "hellow" and replace with the container name)
• Stop the controlhost server (I just stop the container)

By looking at the CPU usage of the python program, it should ramp up to 100%.