Function fold_transaction_range

crates/commitlog/src/commitlog.rs:578–598

(
    repo: R,
    max_log_format_version: u8,
    range: impl RangeBounds<u64>,
    de: D,
)

}

pub fn fold_transaction_range<R, D>(
    repo: R,
    max_log_format_version: u8,
    range: impl RangeBounds<u64>,
    de: D,
) -> Result<(), D::Error>
where
    R: Repo,
    D: Decoder,
    D::Error: From<error::Traversal> + From<io::Error>,
{
    use std::ops::Bound::*;

    let start = match range.start_bound() {
        Included(x) => *x,
        Excluded(x) => x + 1,
        Unbounded => 0,
    };
    let commits = commits_from(repo, max_log_format_version, start)?;
    fold_transactions_internal(commits.with_log_format_version(), de, range)
}

fn transactions_from_internal<'a, R, D, T>(
    commits: CommitsWithVersion<R>,