Type Alias BoxSourceMessageStream 

pub type BoxSourceMessageStream = BoxStream<'static, ConnectorResult<Vec<SourceMessage>>>;

Stream of SourceMessage. Messages flow through the stream in the unit of a batch.

Aliased Type

#[repr(transparent)]
pub struct BoxSourceMessageStream { /* private fields */ }