1
 2
 3
 4
 5
 6
 7
 8
 9
10

use crate::event_processor::EventProcessorActor;
use async_trait::async_trait;

#[async_trait]
pub trait Consumer<M>
where
    M: Send + Clone + Sync + 'static,
{
    async fn get_next_event(&self, event_processor: EventProcessorActor<M>);
}