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