Skip to main content

lines_from_byte_stream

Function lines_from_byte_stream 

Source
pub(crate) fn lines_from_byte_stream(
    stream: BoxStream<'_, Result<Bytes, Error>>,
) -> Pin<Box<LinesStream<StreamReader<BoxStream<'_, Result<Bytes, Error>>, Bytes>>>>
Expand description

Wraps a byte stream as the lines the SSE parsers read, shared by production and tests so a change to how lines are framed cannot drift between them.