Trait mqtt::encodable::Decodable

pub trait Decodable: Sized {
    type Err: Error;
    type Cond;
    pub fn decode_with<R: Read>(
        reader: &mut R, 
        cond: Option<Self::Cond>
    ) -> Result<Self, Self::Err>;

    pub fn decode<R: Read>(reader: &mut R) -> Result<Self, Self::Err> { ... }
}

Methods for decoding bytes to an Object according to MQTT specification

Associated Types

type Err: Error

type Cond

Loading content...

Required methods

pub fn decode_with<R: Read>(
    reader: &mut R,
    cond: Option<Self::Cond>
) -> Result<Self, Self::Err>

Decodes object with additional data (or hints)

Loading content...

Provided methods

pub fn decode<R: Read>(reader: &mut R) -> Result<Self, Self::Err>

Decodes object from reader

Loading content...

Implementations on Foreign Types

impl Decodable for String

type Err = StringEncodeError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<String, StringEncodeError>

impl Decodable for Vec<u8>

type Err = Error

type Cond = u32

pub fn decode_with<R: Read>(
    reader: &mut R,
    length: Option<u32>
) -> Result<Vec<u8>, Error>

impl Decodable for ()

type Err = Infallible

type Cond = ()

pub fn decode_with<R: Read>(_: &mut R, _: Option<()>) -> Result<(), Self::Err>

Loading content...

Implementors

impl Decodable for ConnectReturnCode

type Err = VariableHeaderError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<ConnectReturnCode, VariableHeaderError>

impl Decodable for ProtocolLevel

type Err = VariableHeaderError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<ProtocolLevel, VariableHeaderError>

impl Decodable for VariablePacket

type Err = VariablePacketError

type Cond = FixedHeader

pub fn decode_with<R: Read>(
    reader: &mut R,
    fixed_header: Option<FixedHeader>
) -> Result<VariablePacket, Self::Err>

impl Decodable for FixedHeader

type Err = FixedHeaderError

type Cond = ()

pub fn decode_with<R: Read>(
    rdr: &mut R,
    _rest: Option<()>
) -> Result<FixedHeader, FixedHeaderError>

impl Decodable for ConnackFlags

type Err = VariableHeaderError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<ConnackFlags, VariableHeaderError>

impl Decodable for ConnectFlags

type Err = VariableHeaderError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<ConnectFlags, VariableHeaderError>

impl Decodable for KeepAlive

type Err = VariableHeaderError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<KeepAlive, VariableHeaderError>

impl Decodable for PacketIdentifier

type Err = VariableHeaderError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<PacketIdentifier, VariableHeaderError>

impl Decodable for ProtocolName

type Err = VariableHeaderError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<ProtocolName, VariableHeaderError>

impl Decodable for TopicNameHeader

type Err = VariableHeaderError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<TopicNameHeader, VariableHeaderError>

impl Decodable for VarBytes

type Err = Error

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _: Option<()>
) -> Result<VarBytes, Error>

impl Decodable for ConnectPacketPayload

type Err = ConnectPacketPayloadError

type Cond = ConnectFlags

pub fn decode_with<R: Read>(
    reader: &mut R,
    rest: Option<ConnectFlags>
) -> Result<ConnectPacketPayload, ConnectPacketPayloadError>

impl Decodable for SubackPacketPayload

type Err = SubackPacketPayloadError

type Cond = u32

pub fn decode_with<R: Read>(
    reader: &mut R,
    payload_len: Option<u32>
) -> Result<SubackPacketPayload, SubackPacketPayloadError>

impl Decodable for SubscribePacketPayload

type Err = SubscribePacketPayloadError

type Cond = u32

pub fn decode_with<R: Read>(
    reader: &mut R,
    payload_len: Option<u32>
) -> Result<SubscribePacketPayload, SubscribePacketPayloadError>

impl Decodable for UnsubscribePacketPayload

type Err = UnsubscribePacketPayloadError

type Cond = u32

pub fn decode_with<R: Read>(
    reader: &mut R,
    payload_len: Option<u32>
) -> Result<UnsubscribePacketPayload, UnsubscribePacketPayloadError>

impl Decodable for TopicFilter

type Err = TopicFilterError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<TopicFilter, TopicFilterError>

impl Decodable for TopicName

type Err = TopicNameError

type Cond = ()

pub fn decode_with<R: Read>(
    reader: &mut R,
    _rest: Option<()>
) -> Result<TopicName, TopicNameError>

impl<T: Packet + Debug + 'static> Decodable for T

type Err = PacketError<T>

type Cond = FixedHeader

pub fn decode_with<R: Read>(
    reader: &mut R,
    fixed_header: Option<FixedHeader>
) -> Result<Self, PacketError<Self>>

Loading content...