Trait sqs_lambda::completion_handler::CompletionHandler

pub trait CompletionHandler {
    type Message;
    type CompletedEvent;
#[must_use]    pub fn mark_complete<'life0, 'async_trait>(
        &'life0 self, 
        msg: Self::Message, 
        completed_event: Self::CompletedEvent
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
#[must_use]    pub fn ack_message<'life0, 'async_trait>(
        &'life0 self, 
        msg: Self::Message
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
#[must_use]    pub fn ack_all<'life0, 'async_trait>(
        &'life0 self, 
        notify: Option<Sender<()>>
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

Associated Types

type Message

type CompletedEvent

Loading content...

Required methods

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

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

#[must_use]pub fn ack_all<'life0, 'async_trait>(
    &'life0 self,
    notify: Option<Sender<()>>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Loading content...

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 = SqsMessage

type CompletedEvent = OutputEvent<CE, ProcErr>

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

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

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

Loading content...