Trait SourceParserIntoStreamExt 

pub trait SourceParserIntoStreamExt
where
    Self: ByteStreamSourceParser,
{
    // Required method
    fn parse_stream_with_events(
        self,
        _: BoxSourceMessageEventStream,
    ) -> impl Stream<Item = ConnectorResult<SourceReaderEvent>> + Send;
}

Required Methods

fn parse_stream_with_events( self, _: BoxSourceMessageEventStream, ) -> impl Stream<Item = ConnectorResult<SourceReaderEvent>> + Send

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<P: ByteStreamSourceParser> SourceParserIntoStreamExt for P