Enum ntex_mqtt::error::MqttError

pub enum MqttError<E> {
    Service(E),
    PublishReadyError,
    Decode(DecodeError),
    Encode(EncodeError),
    Unexpected(u8, &'static str),
    PacketIdRequired,
    DuplicatedPacketId,
    KeepAliveTimeout,
    HandshakeTimeout,
    Disconnected,
    Io(Error),
}

Errors which can occur when attempting to handle mqtt connection.

Variants

Service(E)

Publish handler service error

PublishReadyError

Publish service readiness error

Decode(DecodeError)

Mqtt parse error

Encode(EncodeError)

Mqtt encode error

Unexpected(u8, &'static str)

Unexpected packet

PacketIdRequired

"SUBSCRIBE, UNSUBSCRIBE, and PUBLISH (in cases where QoS > 0) Control Packets MUST contain a non-zero 16-bit Packet Identifier [MQTT-2.3.1-1]."

DuplicatedPacketId

Multiple in-flight publish packet with same package_id

KeepAliveTimeout

Keep alive timeout

HandshakeTimeout

Handshake timeout

Disconnected

Peer disconnect

Io(Error)

Unexpected io error

Trait Implementations

impl<E: Debug> Debug for MqttError<E>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<E> From<DecodeError> for MqttError<E>

fn from(err: DecodeError) -> Self

Performs the conversion.

impl<E> From<EncodeError> for MqttError<E>

fn from(err: EncodeError) -> Self

Performs the conversion.

impl<E> From<Error> for MqttError<E>

fn from(err: Error) -> Self

Performs the conversion.