pub struct MqttSink(_);
Implementations
sourceimpl MqttSink
impl MqttSink
sourcepub fn ready(&self) -> impl Future<Output = bool>
pub fn ready(&self) -> impl Future<Output = bool>
Get notification when packet could be send to the peer.
Result indicates if connection is alive
sourcepub fn close_with_reason(&self, pkt: Disconnect)
pub fn close_with_reason(&self, pkt: Disconnect)
Close mqtt connection
sourcepub fn publish<U>(&self, topic: U, payload: Bytes) -> PublishBuilder where
ByteString: From<U>,
pub fn publish<U>(&self, topic: U, payload: Bytes) -> PublishBuilder where
ByteString: From<U>,
Create publish packet builder
sourcepub fn subscribe(&self, id: Option<NonZeroU32>) -> SubscribeBuilder
pub fn subscribe(&self, id: Option<NonZeroU32>) -> SubscribeBuilder
Create subscribe packet builder
sourcepub fn unsubscribe(&self) -> UnsubscribeBuilder
pub fn unsubscribe(&self) -> UnsubscribeBuilder
Create unsubscribe packet builder
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for MqttSink
impl !Send for MqttSink
impl !Sync for MqttSink
impl Unpin for MqttSink
impl !UnwindSafe for MqttSink
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
🔬 This is a nightly-only experimental API. (
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more