fn apply_dml_rate_limit( stream: BoxStream<'static, Result<TxnMsg>>, rate_limiter: Arc<MonitoredRateLimiter>, ) -> impl Stream<Item = Result<TxnMsg, DmlError>>