Struct BatchEventProcessor 

pub struct BatchEventProcessor<T> { /* private fields */ }

Batch Event Processor.

Implementations

impl<T> BatchEventProcessor<T>

pub fn new( ring_buffer: Arc<RingBuffer<T>>, barrier: Arc<ProcessingSequenceBarrier>, handler: Arc<dyn EventHandler<T>>, ) -> Self

Creates a new batch event processor.

pub fn get_sequence(&self) -> Arc<Sequence>

Gets the sequence of the processor.

pub fn run(&self)

Runs the processor loop.