risingwave_connector::parser

Function ensure_largest_at_rate_limit

source 
fn ensure_largest_at_rate_limit(
    stream: BoxSourceStream,
    rate_limit: u32,
) -> impl Stream<Item = Result<Vec<SourceMessage>, ConnectorError>>