apply_rate_limit_to_source_reader_event

risingwave_stream::executor::source

Function apply_rate_limit_to_source_reader_event 

Source 
pub fn apply_rate_limit_to_source_reader_event(
    stream: BoxSourceReaderEventStream,
    rate_limit_rps: Option<u32>,
) -> impl Stream<Item = Result<SourceReaderEvent, ConnectorError>>