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) -> PublishBuilderwhere
ByteString: From<U>,
pub fn publish<U>(&self, topic: U, payload: Bytes) -> PublishBuilderwhere
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 Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
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