This is a simple change to add the ability to send an EOS message to the pipeline. This is important as it allows the pipeline to sort itself out (such as flush buffers and close files) before a pipeline.stop(),
A more generic messaging capability would be better, but this is simple and meets the basic requirement.
Hopefully I have finally got this request right. Bad idea trying to learn GIT and a new IDE (Webstorms) at the same time!
dturing
commented
7 years ago
This is a simple change to add the ability to send an EOS message to the pipeline. This is important as it allows the pipeline to sort itself out (such as flush buffers and close files) before a pipeline.stop(),
A more generic messaging capability would be better, but this is simple and meets the basic requirement.
Hopefully I have finally got this request right. Bad idea trying to learn GIT and a new IDE (Webstorms) at the same time!