Function transactions

crates/commitlog/src/segment.rs:895–916

()

    #[test]
    fn transactions() {
        let repo = repo::Memory::unlimited();
        let commits = vec![
            vec![(0, [1; 32]), (1, [2; 32])],
            vec![(2, [3; 32])],
            vec![(3, [4; 32]), (4, [5; 32])],
        ];

        let mut writer = repo::create_segment_writer(&repo, <_>::default(), Commit::DEFAULT_EPOCH, 0).unwrap();
        for commit in &commits {
            writer.commit(commit.clone()).unwrap();
        }

        writer.flush().unwrap();

        let reader = repo::open_segment_reader(&repo, DEFAULT_LOG_FORMAT_VERSION, 0).unwrap();
        let txs = reader
            .transactions(&ArrayDecoder)
            .collect::<Result<Vec<_>, _>>()
            .unwrap();
        assert_eq!(txs, commits.into_iter().flatten().map(Into::into).collect::<Vec<_>>());
    }

    #[test]
    fn next_tx_offset() {