Enum ntex_mqtt::error::MqttError

pub enum MqttError<E> {
    Service(E),
    Protocol(ProtocolError),
    HandshakeTimeout,
    Disconnected,
    ServerError(&'static str),
}

Errors which can occur when attempting to handle mqtt connection.

Variants

Service(E)

Publish handler service error

Protocol(ProtocolError)

Protocol error

HandshakeTimeout

Handshake timeout

Disconnected

Peer disconnect

ServerError(&'static str)

Server 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<Either<DecodeError, Error>> for MqttError<E>

fn from(err: Either<DecodeError, Error>) -> Self

Performs the conversion.

impl<E> From<Either<EncodeError, Error>> for MqttError<E>

fn from(err: Either<EncodeError, Error>) -> Self

Performs the conversion.

impl<E> From<ProtocolError> for MqttError<E>

fn from(err: ProtocolError) -> Self

Performs the conversion.