Struct DeliveryToken 

pub struct DeliveryToken {
    pub(crate) inner: Arc<TokenInner>,
    msg: Message,
}

A DeliveryToken is a mechanism for tracking the progress of an asynchronous message publish operation.

Fields

inner: Arc<TokenInner>

msg: Message

Implementations

impl DeliveryToken

pub fn new(msg: Message) -> DeliveryToken

Creates a new, un-signaled delivery Token. This is a token which tracks delivery of a message.

pub fn from_error(msg: Message, rc: i32) -> DeliveryToken

Creates a new Token signaled with a return code.

pub fn message(&self) -> &Message

Gets the message associated with the publish token.

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

Blocks the caller until the asynchronous operation completes.

pub fn wait_for(self, dur: Duration) -> Result<(), Error>

Blocks the caller a limited amount of time waiting for the asynchronous operation to complete.

Trait Implementations

impl Clone for DeliveryToken

fn clone(&self) -> DeliveryToken

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl From<DeliveryToken> for Message

fn from(v: DeliveryToken) -> Message

Converts to this type from the input type.

impl Future for DeliveryToken

fn poll( self: Pin<&mut DeliveryToken>, cx: &mut Context<'_>, ) -> Poll<<DeliveryToken as Future>::Output>

Poll the token to see if the request has completed yet.

type Output = Result<(), Error>

The type of value produced on completion.

impl Send for DeliveryToken