Minor Description
My use case is tailing a log and publishing to a websocket. I found that using the handleLine method resulted in too many messages being published. Using a buffer in my listener and only publishing on endOfFileReached was a really simple solution.