Method adjust_initial_offset

crates/commitlog/src/commitlog.rs:828–839

If initial offset falls within a commit, adjust it to the commit boundary. Returns `true` if the initial offset is past `commit`. Returns `false` if `self` isn't `Self::Initial`, or the initial offset has been adjusted to the starting offset of `commit`. For iteration, `true` means to skip the commit, `false` to yield it.

(&mut self, commit: &StoredCommit)

    //
    // For iteration, `true` means to skip the commit, `false` to yield it.
    fn adjust_initial_offset(&mut self, commit: &StoredCommit) -> bool {
        if let Self::Initial { next_offset } = self {
            let last_tx_offset = commit.min_tx_offset + commit.n as u64 - 1;
            if *next_offset > last_tx_offset {
                return true;
            } else {
                *next_offset = commit.min_tx_offset;
            }
        }

        false
    }
}

pub struct Commits<R: Repo> {