krabka_protocol/owned/
offset_commit_value.rs

1// AUTO-GENERATED by krabka-protocol-codegen against a9ce3221537b8653448750697915607dc7936cf3. Do not edit.
2include!(concat!(
3    env!("CARGO_MANIFEST_DIR"),
4    "/generated/OffsetCommitValue.owned.rs"
5));
6#[cfg(test)]
7mod tests {
8    use assert2::assert;
9    use bytes::BytesMut;
10
11    use super::*;
12    use crate::{Decode, Encode};
13    fn roundtrip(msg: &OffsetCommitValue, v: i16) {
14        let mut buf = BytesMut::new();
15        msg.encode(&mut buf, v).unwrap();
16        assert!(msg.encoded_len(v) == buf.len());
17        let bytes = buf.freeze();
18        let mut cur = &bytes[..];
19        let decoded = OffsetCommitValue::decode(&mut cur, v).unwrap();
20        assert!(cur.is_empty());
21        let mut reencoded = BytesMut::new();
22        decoded.encode(&mut reencoded, v).unwrap();
23        assert!(&reencoded[..] == &bytes[..]);
24        let _ = default_json(v);
25    }
26    #[test]
27    fn default_roundtrips_all_versions() {
28        for v in MIN_VERSION..=MAX_VERSION {
29            roundtrip(&OffsetCommitValue::default(), v);
30        }
31    }
32    #[test]
33    fn populated_roundtrips_all_versions() {
34        for v in MIN_VERSION..=MAX_VERSION {
35            roundtrip(&OffsetCommitValue::populated(v), v);
36        }
37    }
38    #[test]
39    fn tagged_fixture_roundtrips_all_versions() {
40        for v in MIN_VERSION..=MAX_VERSION {
41            roundtrip(&tagged_fixture(), v);
42            assert!(tagged_fixture_json(v).is_object());
43        }
44        let encode = |msg: &OffsetCommitValue| {
45            let mut buf = BytesMut::new();
46            msg.encode(&mut buf, MAX_VERSION).unwrap();
47            buf
48        };
49        assert!(encode(&tagged_fixture()) != encode(&OffsetCommitValue::default()));
50    }
51}
krabka_protocol/owned/offset_commit_value.rs

krabka_protocol/owned/
offset_commit_value.rs
