Enum ntex_mqtt::v5::client::control::ControlMessage

pub enum ControlMessage<E> {
    Publish(Publish),
    Disconnect(Disconnect),
    Error(Error<E>),
    ProtocolError(ProtocolError),
    Closed(Closed),
}

Variants

Publish(Publish)

Tuple Fields

0: Publish

Unhandled publish packet

Disconnect(Disconnect)

Tuple Fields

0: Disconnect

Disconnect packet

Error(Error<E>)

Tuple Fields

0: Error<E>

Application level error from resources and control services

ProtocolError(ProtocolError)

Tuple Fields

0: ProtocolError

Protocol level error

Closed(Closed)

Tuple Fields

0: Closed

Connection closed

Implementations

impl<E> ControlMessage<E>

pub fn disconnect(&self, pkt: Disconnect) -> ControlResult