How do you handle graceful shutdown? We would like to leave the pipeline running until the sink receives an end_of_stream and finishes his work. Is there any recommended way to handle this?

When stopping the application I can see the following logs:

iex(4)> :init.stop
:ok
Pepe.Pipeline/ Pipeline supervisor got exit from a linked process, stopping pipeline
Pepe.Pipeline/ Pipeline supervisor got exit from pipeline with reason :shutdown, stopping subprocess supervisor
....and for all the components