Method fold_transaction_range

crates/commitlog/src/commitlog.rs:348–361

(&self, range: impl RangeBounds<u64>, decoder: D)

    }

    pub fn fold_transaction_range<D>(&self, range: impl RangeBounds<u64>, decoder: D) -> Result<(), D::Error>
    where
        D: Decoder,
        D::Error: From<error::Traversal>,
    {
        use std::ops::Bound::*;

        let start = match range.start_bound() {
            Included(x) => *x,
            Excluded(x) => x + 1,
            Unbounded => 0,
        };
        fold_transactions_internal(self.commits_from(start).with_log_format_version(), decoder, range)
    }
}

impl<R: Repo, T> Drop for Generic<R, T> {