Method into_transactions

crates/commitlog/src/commit.rs:222–244

Convert `self` into an iterator yielding [`Transaction`]s. The supplied [`Decoder`] is responsible for extracting individual transactions from the `records` buffer. `version` is the log format version of the current segment, and gets passed to [`Decoder::decode_record`]. `from_offset` is the transaction offset within the current commit from which to start decoding. That is: if the tx offset wi

(
        self,
        version: u8,
        from_offset: u64,
        de: &D,
    )

    ///   yields nothing.
    ///
    pub fn into_transactions<D: Decoder>(
        self,
        version: u8,
        from_offset: u64,
        de: &D,
    ) -> impl Iterator<Item = Result<Transaction<D::Record>, D::Error>> + '_ {
        let records = Cursor::new(self.records);
        (self.min_tx_offset..(self.min_tx_offset + self.n as u64))
            .scan(records, move |recs, offset| {
                let mut cursor = &*recs;
                let ret = if offset < from_offset {
                    de.skip_record(version, offset, &mut cursor).err().map(Err)
                } else {
                    let tx = de
                        .decode_record(version, offset, &mut cursor)
                        .map(|txdata| Transaction { offset, txdata });
                    Some(tx)
                };

                Some(ret)
            })
            .flatten()
    }
}

impl From<StoredCommit> for Commit {