Enum Control 

pub enum Control<E> {
    Auth(Auth),
    PublishRelease(PublishRelease),
    Ping(Ping),
    Disconnect(Disconnect),
    Subscribe(Subscribe),
    Unsubscribe(Unsubscribe),
    WrBackpressure(WrBackpressure),
    Closed(Closed),
    Error(Error<E>),
    ProtocolError(ProtocolError),
    PeerGone(PeerGone),
}

Server control messages

Variants

Auth(Auth)

Auth packet from a client

PublishRelease(PublishRelease)

PublishRelease packet from a client

Ping(Ping)

Ping packet from a client

Disconnect(Disconnect)

Disconnect packet from a client

Subscribe(Subscribe)

Subscribe packet from a client

Unsubscribe(Unsubscribe)

Unsubscribe packet from a client

WrBackpressure(WrBackpressure)

Write back-pressure is enabled/disabled

Closed(Closed)

Underlying transport connection closed

Error(Error<E>)

Unhandled application level error from handshake, publish and control services

ProtocolError(ProtocolError)

Protocol level error

PeerGone(PeerGone)

Peer is gone

Implementations

impl<E> Control<E>

pub fn disconnect(&self) -> ControlAck

Disconnects the client by sending DISCONNECT packet with NormalDisconnection reason code.

pub fn disconnect_with(&self, pkt: Disconnect) -> ControlAck

Disconnects the client by sending DISCONNECT packet with provided reason code.

pub fn ack(self) -> ControlAck

Ack control message

Trait Implementations

impl<E: Debug> Debug for Control<E>

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

Formats the value using the given formatter.