Struct ntex_mqtt::v5::Publish [−][src]
pub struct Publish { /* fields omitted */ }
Publish message
Implementations
impl Publish
[src]
impl Publish
[src]pub fn dup(&self) -> bool
[src]
this might be re-delivery of an earlier attempt to send the Packet.
pub fn retain(&self) -> bool
[src]
pub fn qos(&self) -> QoS
[src]
the level of assurance for delivery of an Application Message.
pub fn publish_topic(&self) -> &str
[src]
the information channel to which payload data is published.
pub fn id(&self) -> Option<NonZeroU16>
[src]
only present in PUBLISH Packets where the QoS level is 1 or 2.
pub fn topic(&self) -> &Path<ByteString>
[src]
pub fn topic_mut(&mut self) -> &mut Path<ByteString>
[src]
pub fn packet(&self) -> &Publish
[src]
pub fn packet_mut(&mut self) -> &mut Publish
[src]
pub fn payload(&self) -> &Bytes
[src]
the Application Message that is being published.
pub fn take_payload(&self) -> Bytes
[src]
Extract Bytes from packet payload
pub fn json<T: DeserializeOwned>(&mut self) -> Result<T, JsonError>
[src]
Loads and parse application/json
encoded body.
pub fn ack(self) -> PublishAck
[src]
Create acknowledgement for this packet
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Publish
impl RefUnwindSafe for Publish
impl UnwindSafe for Publish
impl UnwindSafe for Publish
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
Should always be Self