risingwave_connector::source::base

Type Alias BoxSourceStream

source
pub type BoxSourceStream = BoxStream<'static, ConnectorResult<Vec<SourceMessage>>>;
Expand description

Stream of SourceMessage.

Aliased Typeยง

struct BoxSourceStream {}