Trait SourceParserIntoStreamExt

pub trait SourceParserIntoStreamExt
where
    Self: ByteStreamSourceParser,
{
    // Required method
    fn into_stream(self, _: BoxSourceStream) -> impl ChunkSourceStream;
}

Required Methods

fn into_stream(self, _: BoxSourceStream) -> impl ChunkSourceStream

Parse a data stream of one source split into a stream of StreamChunk.

Arguments

• data_stream: A data stream of one source split. To be able to split multiple messages from mq, so it is not a pure byte stream

Returns

A ChunkSourceStream which is a stream of parsed messages.

Object Safety

This trait is not object safe.

Implementors

impl<P: ByteStreamSourceParser> SourceParserIntoStreamExt for P