Extends StreamTransformInterceptor
This interceptor cares about the handling of the messages. It will add the hops and copies the messages
This module reads a stream and split it into lines. The out put stream will be an object stream
Creates the line parser and sets the options. The following options are supported: { "allow_new_line_in_cell" : true, "line_separator" : "\n", "quote_char" : '"' "skip_empty_lines" : true }
opts(optional, default{})
Reads the stream data and split it into lines.
dataenccb
Returns the rest as line
cb
Pushes a line object onto the stream
data