Function read_from_lsn_with_limit

nodedb/src/event/cdc/buffer.rs:328–339

()

    #[test]
    fn read_from_lsn_with_limit() {
        let buf = StreamBuffer::new("test".into(), RetentionConfig::default());

        for i in 1..=10 {
            buf.push(make_event(i, i * 10));
        }

        let events = buf.read_from_lsn(0, 3);
        assert_eq!(events.len(), 3);
        assert_eq!(events[0].lsn, 10);
        assert_eq!(events[2].lsn, 30);
    }

    fn make_event_on_partition(seq: u64, partition: u32, lsn: u64) -> CdcEvent {
        let mut e = make_event(seq, lsn);