Struct NoticeFuture

pub struct NoticeFuture(/* private fields */);

A token through which the user is notified of the publish/subscribe/unsubscribe packet being acked by the broker.

Implementations

impl NoticeFuture

pub fn wait(self) -> Result<(), NoticeError>

Wait for broker to acknowledge by blocking the current thread

Panics

Panics if called in an async context

pub async fn wait_async(self) -> Result<(), NoticeError>

Await the packet acknowledgement from broker, without blocking the current thread

pub fn try_wait(&mut self) -> Option<Result<(), NoticeError>>

Attempts to check if the broker acknowledged the packet, without blocking the current thread or consuming the notice.

It will return None if the packet wasn’t acknowledged.

Multiple calls to this functions can fail with NoticeError::Recv if the notice was already waited and the packet was already acknowledged and Some value was returned.

Trait Implementations

impl Debug for NoticeFuture

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

Formats the value using the given formatter.