[−][src]Trait sqs_lambda::completion_handler::CompletionHandler

pub trait CompletionHandler {
    type Message;
    type CompletedEvent;
    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;

    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;

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

Associated Types

type Message

type CompletedEvent

Loading content...

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
    'life0: 'async_trait,
    Self: 'async_trait, 

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, 

fn release<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    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 + Clone + 'static,
    SqsT: Sqs + Clone + Send + Sync + 'static, [src]

type Message = SqsMessage

type CompletedEvent = OutputEvent<CE, ProcErr>

impl<Err, CE, EventSerializer> CompletionHandler for FsCompletionHandlerActor<Err, CE, EventSerializer> where
    Err: Debug + Send + Sync + Clone + 'static,
    CE: Send + Sync + Clone + 'static,
    EventSerializer: CompletionEventSerializer<CompletedEvent = CE, Output = Vec<u8>, Error = Error<Err>> + Send + Sync + Clone + 'static, [src]

type Message = FsEvent

type CompletedEvent = OutputEvent<CE, Error<Err>>

Loading content...