Function deltalake::storage::object_store::delimited::newline_delimited_stream

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

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