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

struct BoxSourceMessageStream {}