risingwave_stream::executor::source

Function apply_rate_limit

source 
pub fn apply_rate_limit(
    stream: BoxChunkSourceStream,
    rate_limit_rps: Option<u32>,
) -> impl Stream<Item = Result<StreamChunk, ConnectorError>>