Struct embedded_svc::utils::asyncify::mqtt::client::AsyncConnection

pub struct AsyncConnection<CV, M, E>(/* private fields */)
where
    CV: RawCondvar;

Implementations

impl<CV, M, E> AsyncConnection<CV, M, E>

where CV: RawCondvar,

pub fn new( connection_state: Arc<ConnStateGuard<CV, AsyncConnState<M, E>>> ) -> Self

impl<CV, M, E> AsyncConnection<CV, M, E>

where CV: RawCondvar + Send + Sync + 'static, CV::RawMutex: Sync + 'static, M: Send, E: Debug + Send + 'static,

pub async fn next(&mut self) -> Option<Result<Event<M>, E>>

Trait Implementations

impl<CV, M, E> Drop for AsyncConnection<CV, M, E>

where CV: RawCondvar,

fn drop(&mut self)

Executes the destructor for this type.