rabbitmq_stream_protocol/
error.rs

1use std::string::FromUtf8Error;
2
3#[derive(Debug)]
4pub enum DecodeError {
5    Incomplete(IncompleteError),
6    Utf8Error(FromUtf8Error),
7    UnknownResponseCode(u16),
8    UnsupportedResponseType(u16),
9    MismatchSize(usize),
10    MessageParse(String),
11    InvalidFormatCode(u8),
12    Empty,
13}
14
15#[derive(Debug)]
16pub enum EncodeError {
17    Io(std::io::Error),
18    MaxSizeError(usize),
19}
20
21impl From<std::io::Error> for EncodeError {
22    fn from(err: std::io::Error) -> Self {
23        EncodeError::Io(err)
24    }
25}
26
27impl From<FromUtf8Error> for DecodeError {
28    fn from(err: FromUtf8Error) -> Self {
29        DecodeError::Utf8Error(err)
30    }
31}
32
33impl From<IncompleteError> for DecodeError {
34    fn from(err: IncompleteError) -> Self {
35        DecodeError::Incomplete(err)
36    }
37}
38
39#[derive(Debug)]
40pub struct IncompleteError(pub usize);

rabbitmq_stream_protocol/error.rs

rabbitmq_stream_protocol/
error.rs