Struct MqttPublisher

Source

pub struct MqttPublisher { /* private fields */ }

Expand description

Publishes messages to MQTT topics through the shared connection.

The publish is queued into the client session: for QoS 1/2 the session’s state machine retransmits until the broker acknowledges (surviving reconnects), so Ok means “owned by the session”, not “broker confirmed”. Buildable before connect and usable until shutdown; afterwards every publish reports MqttError::NotConnected.

MqttPublisher

Struct MqttPublisher Copy item path

Trait Implementations§

impl Clone for MqttPublisher

fn clone(&self) -> MqttPublisher

fn clone_from(&mut self, source: &Self)

impl Debug for MqttPublisher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl Publisher for MqttPublisher

type Error = MqttError

async fn publish(&self, msg: OutgoingMessage<'_>) -> Result<(), Self::Error>

Auto Trait Implementations§

impl !RefUnwindSafe for MqttPublisher

impl !UnwindSafe for MqttPublisher

impl Freeze for MqttPublisher

impl Send for MqttPublisher

impl Sync for MqttPublisher

impl Unpin for MqttPublisher

impl UnsafeUnpin for MqttPublisher

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<P> ErasedPublisher for Pwhere P: Publisher,

fn publish_bytes<'a>( &'a self, name: &'a str, payload: &'a [u8], ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Sync + Send>>> + Send + 'a>>

fn publish_message<'a>( &'a self, name: &'a str, payload: &'a [u8], headers: &'a Headers, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Sync + Send>>> + Send + 'a>>

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<Reply, DeliveryCx, Pipeline, Bare> ReplySink<Reply, DeliveryCx, Pipeline> for Barewhere Reply: AsRef<[u8]> + Sync, DeliveryCx: Sync, Pipeline: Send + Sync, Bare: Publisher,

type Error = <Bare as Publisher>::Error

async fn deliver( &self, name: &str, reply: &Reply, _pipeline: &Pipeline, _cx: &PublishContext<'_, DeliveryCx>, ) -> Result<(), <Bare as ReplySink<Reply, DeliveryCx, Pipeline>>::Error>

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct MqttPublisher

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<P> ErasedPublisher for P
where P: Publisher,

impl<T, U> Into<U> for T
where U: From<T>,

impl<Reply, DeliveryCx, Pipeline, Bare> ReplySink<Reply, DeliveryCx, Pipeline> for Bare
where Reply: AsRef<[u8]> + Sync, DeliveryCx: Sync, Pipeline: Send + Sync, Bare: Publisher,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,