Struct ntex_mqtt::v5::client::MqttSink [−][src]
pub struct MqttSink(_);
Implementations
impl MqttSink
[src]
impl MqttSink
[src]pub fn is_open(&self) -> bool
[src]
Check connection status
pub fn credit(&self) -> usize
[src]
Get client’s receive credit
pub fn ready(&self) -> impl Future<Output = bool>
[src]
Get notification when packet could be send to the peer.
Result indicates if connection is alive
pub fn close(&self)
[src]
Close mqtt connection with default Disconnect message
pub fn close_with_reason(&self, pkt: Disconnect)
[src]
Close mqtt connection
pub fn publish<U>(&self, topic: U, payload: Bytes) -> PublishBuilder where
ByteString: From<U>,
[src]
ByteString: From<U>,
Create publish packet builder
pub fn subscribe(&self, id: Option<NonZeroU32>) -> SubscribeBuilder
[src]
Create subscribe packet builder
pub fn unsubscribe(&self) -> UnsubscribeBuilder
[src]
Create unsubscribe packet builder
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for MqttSink
impl !RefUnwindSafe for MqttSink
impl !UnwindSafe for MqttSink
impl !UnwindSafe for MqttSink
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