EnvelopeStack

strut_rabbitmq

Trait EnvelopeStack 

Source 
pub trait EnvelopeStack {
    // Required methods
    fn complete_all<'async_trait>(
        self,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait;
    fn backwash_all<'async_trait>(
        self,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait;
    fn abandon_all<'async_trait>(
        self,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait;
}
Expand description

Represents a collection of Envelopes that can be acted upon with included convenience methods.

Required Methods§

Source

fn complete_all<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait,

Efficiently calls complete on every envelope in this stack.

Source

fn backwash_all<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait,

Efficiently calls backwash on every envelope in this stack.

Source

fn abandon_all<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait,

Efficiently calls abandon on every envelope in this stack.

Implementations on Foreign Types§

Source§

impl<T> EnvelopeStack for Vec<Envelope<T>>
where T: Send,

Implements EnvelopeStack for a vector of Envelopes.

Source§

fn complete_all<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait,

Source§

fn backwash_all<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait,

Source§

fn abandon_all<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait,

Implementors§

Source§

impl<T> EnvelopeStack for NonEmpty<Envelope<T>>
where T: Send,

Implements EnvelopeStack for a NonEmpty collection of Envelopes.