Trait CompletionHandler 

pub trait CompletionHandler {
    type Message;
    type CompletedEvent;

    // Required methods
    fn mark_complete<'life0, 'async_trait>(
        &'life0 self,
        msg: Self::Message,
        completed_event: Self::CompletedEvent,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn ack_message<'life0, 'async_trait>(
        &'life0 self,
        msg: Self::Message,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn ack_all<'life0, 'async_trait>(
        &'life0 self,
        notify: Option<Sender<()>>,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Associated Types

type Message

type CompletedEvent

Required Methods

fn mark_complete<'life0, 'async_trait>( &'life0 self, msg: Self::Message, completed_event: Self::CompletedEvent, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn ack_message<'life0, 'async_trait>( &'life0 self, msg: Self::Message, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn ack_all<'life0, 'async_trait>( &'life0 self, notify: Option<Sender<()>>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors

impl<CE, ProcErr, SqsT> CompletionHandler for SqsCompletionHandlerActor<CE, ProcErr, SqsT>

where CE: Send + Sync + Clone + 'static, ProcErr: Debug + Send + Sync + 'static, SqsT: Sqs + Clone + Send + Sync + 'static,

type Message = Message

type CompletedEvent = OutputEvent<CE, ProcErr>