Struct sqs_lambda::sqs_completion_handler::SqsCompletionHandlerActor

pub struct SqsCompletionHandlerActor<CE> where
    CE: Send + Sync + 'static,  { /* fields omitted */ }

Methods

impl<CE> SqsCompletionHandlerActor<CE> where
    CE: Send + Sync + 'static, 

pub fn new<CPE, CP, Payload, EE>(
    actor_impl: SqsCompletionHandler<CPE, CP, CE, Payload, EE>
) -> Self where
    CPE: Send + Sync + 'static,
    CP: CompletionEventSerializer<CompletedEvent = CE, Output = Payload, Error = CPE> + Send + Sync + 'static,
    Payload: Send + Sync + 'static,
    EE: EventEmitter<Event = Payload> + Send + Sync + 'static, 

pub async fn mark_complete<'_>(&'_ self, msg: SqsMessage, completed: CE)

pub async fn ack_all<'_>(&'_ self)

Trait Implementations

impl<CE: Clone> Clone for SqsCompletionHandlerActor<CE> where
    CE: Send + Sync + 'static, 

fn clone(&self) -> SqsCompletionHandlerActor<CE>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<CE> CompletionHandler for SqsCompletionHandlerActor<CE> where
    CE: Send + Sync + 'static, 

type Message = SqsMessage

type CompletedEvent = CE

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,