Function newline_delimited_stream

pub fn newline_delimited_stream<S>(s: S) -> impl Stream<Item = Result<Bytes>>
where
    S: Stream<Item = Result<Bytes>> + Unpin,

Given a Stream of Bytes returns a Stream where each yielded Bytes contains a whole number of new line delimited records accounting for \ style escapes and " quotes