crabka_protocol/borrowed/
offset_commit_response.rs

1// AUTO-GENERATED by crabka-protocol-codegen against a9ce3221537b8653448750697915607dc7936cf3. Do not edit.
2// Clippy lints that fire on generated code patterns are suppressed here so
3// that regenerating the file does not require manual allow annotations.
4#![allow(
5    clippy::absurd_extreme_comparisons,
6    clippy::cast_possible_truncation,
7    clippy::cast_possible_wrap,
8    clippy::cast_sign_loss,
9    clippy::default_trait_access,
10    clippy::must_use_candidate,
11    clippy::new_without_default,
12    clippy::nonminimal_bool,
13    clippy::too_many_lines,
14    clippy::unnecessary_wraps,
15    clippy::unreadable_literal,
16    unused_mut,
17    unused_variables
18)]
19
20include!(concat!(
21    env!("CARGO_MANIFEST_DIR"),
22    "/generated/OffsetCommitResponse.borrowed.rs"
23));
24#[cfg(test)]
25mod tests {
26    use assert2::assert;
27    use bytes::BytesMut;
28
29    use super::*;
30    use crate::{DecodeBorrow, Encode};
31    fn check(msg_bytes: &bytes::Bytes, v: i16) {
32        let mut cur: &[u8] = msg_bytes;
33        let decoded = OffsetCommitResponse::decode_borrow(&mut cur, v).unwrap();
34        assert!(cur.is_empty());
35        assert!(decoded.encoded_len(v) == msg_bytes.len());
36        let mut reencoded = BytesMut::new();
37        decoded.encode(&mut reencoded, v).unwrap();
38        assert!(&reencoded[..] == &msg_bytes[..]);
39        let owned = decoded.to_owned();
40        let mut owned_buf = BytesMut::new();
41        owned.encode(&mut owned_buf, v).unwrap();
42        assert!(&owned_buf[..] == &msg_bytes[..]);
43    }
44    #[test]
45    fn default_roundtrips_all_versions() {
46        for v in MIN_VERSION..=MAX_VERSION {
47            let msg = OffsetCommitResponse::default();
48            let mut buf = BytesMut::new();
49            msg.encode(&mut buf, v).unwrap();
50            check(&buf.freeze(), v);
51        }
52    }
53    #[test]
54    fn populated_roundtrips_all_versions() {
55        for v in MIN_VERSION..=MAX_VERSION {
56            let msg = OffsetCommitResponse::populated(v);
57            let mut buf = BytesMut::new();
58            msg.encode(&mut buf, v).unwrap();
59            check(&buf.freeze(), v);
60        }
61    }
62}
crabka_protocol/borrowed/offset_commit_response.rs

crabka_protocol/borrowed/
offset_commit_response.rs
