Enum ClientEvent
pub enum ClientEvent<'a> {
Connected {
session_present: bool,
capabilities: ServerCapabilities,
},
MessageReceived {
topic: Option<&'a Topic>,
payload: &'a [u8],
qos: QoS,
retain: bool,
},
PublishAcked {
packet_id: PacketId,
reason_code: ReasonCode,
},
PublishComplete {
packet_id: PacketId,
reason_code: ReasonCode,
},
SubscribeAcked {
packet_id: PacketId,
reason_codes: &'a [u8],
},
UnsubscribeAcked {
packet_id: PacketId,
reason_codes: &'a [u8],
},
Disconnected {
reason_code: ReasonCode,
},
PingResponse,
}Expand description
Events produced by the client state machine for the application layer.
Variants§
Connected
Connection established successfully.
Fields
§
capabilities: ServerCapabilitiesServer-advertised capabilities from CONNACK properties.
MessageReceived
An application message was received (server → client PUBLISH).
Fields
PublishAcked
A QoS 1 publish was acknowledged (PUBACK received).
Fields
§
reason_code: ReasonCodeReason code from the PUBACK.
PublishComplete
A QoS 2 publish flow completed (PUBCOMP received, or PUBREC with
error reason code).
Fields
§
reason_code: ReasonCodeReason code from the final acknowledgement.
SubscribeAcked
SUBACK received.
Fields
UnsubscribeAcked
UNSUBACK received.
Fields
Disconnected
Server sent DISCONNECT.
Fields
§
reason_code: ReasonCodeReason code from the DISCONNECT packet.
PingResponse
PINGRESP received.
Trait Implementations§
Auto Trait Implementations§
impl<'a> Freeze for ClientEvent<'a>
impl<'a> RefUnwindSafe for ClientEvent<'a>
impl<'a> Send for ClientEvent<'a>
impl<'a> Sync for ClientEvent<'a>
impl<'a> Unpin for ClientEvent<'a>
impl<'a> UnwindSafe for ClientEvent<'a>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more