Trait sqs_lambda::event_retriever::PayloadRetriever

pub trait PayloadRetriever<T> {
    type Message;
#[must_use]    pub fn retrieve_event<'life0, 'life1, 'async_trait>(
        &'life0 mut self, 
        msg: &'life1 Self::Message
    ) -> Pin<Box<dyn Future<Output = Result<Option<T>, Box<dyn Error>>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;
}

Associated Types

type Message

Loading content...

Required methods

#[must_use]pub fn retrieve_event<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    msg: &'life1 Self::Message
) -> Pin<Box<dyn Future<Output = Result<Option<T>, Box<dyn Error>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Loading content...

Implementors

impl<S, SInit, D, E> PayloadRetriever<E> for S3PayloadRetriever<S, SInit, D, E> where
    S: S3 + Clone + Send + Sync + 'static,
    SInit: Fn(String) -> S + Clone + Send + Sync + 'static,
    D: PayloadDecoder<E> + Clone + Send + 'static,
    E: Send + 'static, 

type Message = SqsMessage

pub fn retrieve_event<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    msg: &'life1 Self::Message
) -> Pin<Box<dyn Future<Output = Result<Option<E>, Box<dyn Error>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Loading content...