amqpr_codec/frame/content_body/
mod.rs

1pub mod decoder;
2pub mod encoder;
3
4pub use self::decoder::decode_payload;
5
6use bytes::Bytes;
7
8
9/// Content body payload is just binary payload
10#[derive(Eq, PartialEq, Clone, Debug)]
11pub struct ContentBodyPayload {
12    pub bytes: Bytes,
13}
14
15
16impl ContentBodyPayload {
17    pub fn byte_size(&self) -> u32 {
18        // length of payload + frame-end
19        (self.bytes.len() + 1) as u32
20    }
21}