sqs_lambda/
consumer.rs

1use crate::event_processor::EventProcessorActor;
2use async_trait::async_trait;
3
4#[async_trait]
5pub trait Consumer<M>
6where
7    M: Send + Clone + Sync + 'static,
8{
9    async fn get_next_event(&self, event_processor: EventProcessorActor<M>);
10}