crabka_protocol/owned/
offset_commit_response.rs1#![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.owned.rs"
23));
24
25#[cfg(test)]
26mod tests {
27 use super::*;
28 use crate::{Decode, Encode};
29 use assert2::assert;
30 use bytes::BytesMut;
31
32 fn roundtrip(msg: &OffsetCommitResponse, v: i16) {
33 let mut buf = BytesMut::new();
34 msg.encode(&mut buf, v).unwrap();
35 assert!(msg.encoded_len(v) == buf.len());
36 let bytes = buf.freeze();
37 let mut cur = &bytes[..];
38 let decoded = OffsetCommitResponse::decode(&mut cur, v).unwrap();
39 assert!(cur.is_empty());
40 let mut reencoded = BytesMut::new();
41 decoded.encode(&mut reencoded, v).unwrap();
42 assert!(&reencoded[..] == &bytes[..]);
43 let _ = default_json(v);
45 }
46
47 #[test]
48 fn default_roundtrips_all_versions() {
49 for v in MIN_VERSION..=MAX_VERSION {
50 roundtrip(&OffsetCommitResponse::default(), v);
51 }
52 }
53
54 #[test]
55 fn populated_roundtrips_all_versions() {
56 for v in MIN_VERSION..=MAX_VERSION {
57 roundtrip(&OffsetCommitResponse::populated(v), v);
58 }
59 }
60}