rabbitmq-stream-protocol 0.11.0

AMQP 1.0 message codec
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use std::{any::type_name, io::Write};

use self::constants::TypeCode;

use super::error::{AmqpDecodeError, AmqpEncodeError};

pub mod constants;
mod decoder;

pub trait AmqpEncoder {
    fn encoded_size(&self) -> u32;
    fn encode(&self, writer: &mut impl Write) -> Result<(), AmqpEncodeError>;
}

pub trait AmqpDecoder
where
    Self: Sized,
{
    fn decode(input: &[u8]) -> Result<(&[u8], Self), AmqpDecodeError>;

    fn invalid_type_code(code: TypeCode) -> AmqpDecodeError {
        AmqpDecodeError::InvalidTypeCodeFor {
            target: type_name::<Self>().to_string(),
            code,
        }
    }
}