[−][src]Trait sqs_lambda::event_emitter::EventEmitter
Associated Types
Loading content...Required methods
fn emit_event<'life0, 'async_trait>(
&'life0 mut self,
completed_events: Vec<Self::Event>
) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
&'life0 mut self,
completed_events: Vec<Self::Event>
) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Implementors
impl EventEmitter for FsEventEmitter
[src]
type Event = Vec<u8>
type Error = Error<()>
fn emit_event<'life0, 'async_trait>(
&'life0 mut self,
completed_events: Vec<Self::Event>
) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
[src]
&'life0 mut self,
completed_events: Vec<Self::Event>
) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
impl<S, F, OnEmission, EmissionResult> EventEmitter for S3EventEmitter<S, F, OnEmission, EmissionResult> where
S: S3 + Send + Sync + 'static,
F: Fn(&[u8]) -> String + Send + Sync,
EmissionResult: Future<Output = Result<(), Box<dyn Error + Send + Sync + 'static>>> + Send + 'static,
OnEmission: Fn(String, String) -> EmissionResult + Send + Sync + 'static,
[src]
S: S3 + Send + Sync + 'static,
F: Fn(&[u8]) -> String + Send + Sync,
EmissionResult: Future<Output = Result<(), Box<dyn Error + Send + Sync + 'static>>> + Send + 'static,
OnEmission: Fn(String, String) -> EmissionResult + Send + Sync + 'static,