Struct sqs_lambda::fs_event_retriever::FsRetriever

pub struct FsRetriever<D, E> where
    D: PayloadDecoder<E> + Clone + Send + 'static,
    E: Send + 'static,  { /* fields omitted */ }

Implementations

impl<D, E> FsRetriever<D, E> where
    D: PayloadDecoder<E> + Clone + Send + 'static,
    E: Send + 'static, 

pub fn new(decoder: D) -> Self

Trait Implementations

impl<D: Clone, E: Clone> Clone for FsRetriever<D, E> where
    D: PayloadDecoder<E> + Clone + Send + 'static,
    E: Send + 'static, 

fn clone(&self) -> FsRetriever<D, E>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<D, E> PayloadRetriever<E> for FsRetriever<D, E> where
    D: PayloadDecoder<E> + Clone + Send + 'static,
    E: Send + 'static, 

type Message = FsEvent

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