Struct ntex_mqtt::v3::client::MqttSink [−][src]
pub struct MqttSink(_);
Implementations
impl MqttSink
[src]
impl MqttSink
[src]pub fn credit(&self) -> usize
[src]
Get client 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
pub fn force_close(&self)
[src]
Force close mqtt connection. mqtt dispatcher does not wait for uncompleted responses, but it flushes buffers.
pub fn publish(&self, topic: ByteString, payload: Bytes) -> PublishBuilder
[src]
Create publish message builder
pub fn subscribe(&self) -> SubscribeBuilder
[src]
Create subscribe packet builder
panics if id is 0
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