Struct embedded_svc::utils::asyncify::mqtt::client::AsyncClient

pub struct AsyncClient<U, W>(/* private fields */);

Implementations

impl<U, W> AsyncClient<U, W>

pub const fn new(unblocker: U, client: W) -> Self

impl<E> AsyncClient<(), Blocking<E, Enqueueing>>

where E: Enqueue + Send,

pub async fn publish<'a>( &'a mut self, topic: &'a str, qos: QoS, retain: bool, payload: &'a [u8] ) -> Result<MessageId, E::Error>

impl<P> AsyncClient<(), Blocking<P, Publishing>>

where P: Publish + Send,

pub async fn publish<'a>( &'a mut self, topic: &'a str, qos: QoS, retain: bool, payload: &'a [u8] ) -> Result<MessageId, P::Error>

impl<C, P> AsyncClient<(), Blocking<C, P>>

where C: Client + Send,

pub async fn subscribe<'a>( &'a mut self, topic: &'a str, qos: QoS ) -> Result<MessageId, C::Error>

pub async fn unsubscribe<'a>( &'a mut self, topic: &'a str ) -> Result<MessageId, C::Error>

impl<C> AsyncClient<(), Blocking<C, Publishing>>

pub fn into_enqueueing(self) -> AsyncClient<(), Blocking<C, Enqueueing>>

impl<C> AsyncClient<(), Blocking<C, Enqueueing>>

pub fn into_publishing(self) -> AsyncClient<(), Blocking<C, Publishing>>

Trait Implementations

impl<C> AsyncWrapper<C> for AsyncClient<(), Blocking<C, Publishing>>

fn new(sync: C) -> Self

impl<U, R, C> UnblockingAsyncWrapper<U, C> for AsyncClient<U, Arc<Mutex<R, C>>>

where R: RawMutex,

fn new(unblocker: U, sync: C) -> Self