Struct ntex_mqtt::v3::client::MqttSink [−][src]
pub struct MqttSink(_);
Implementations
impl MqttSink
[src]
impl MqttSink
[src]pub fn ready(&self) -> impl Future<Output = bool>
[src]
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 force_close(&self)
[src]
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]
pub fn publish(&self, topic: ByteString, payload: Bytes) -> PublishBuilder
[src]Create publish message builder
pub fn unsubscribe(&self) -> UnsubscribeBuilder
[src]
pub fn unsubscribe(&self) -> UnsubscribeBuilder
[src]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
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
type Output = T
Should always be Self
impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
[src]type Owned = T
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn to_owned(&self) -> T
[src]Creates owned data from borrowed data, usually by cloning. Read more
pub fn clone_into(&self, target: &mut T)
[src]
pub fn clone_into(&self, target: &mut T)
[src]🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more