Trait nakadion::TypedBatchHandler

pub trait TypedBatchHandler {
    type Event: DeserializeOwned;
    fn handle(&mut self, events: Vec<Self::Event>) -> TypedProcessingStatus;
}

Basically the same a BatchHandler with the difference that deserialized events are passed to the processing logic.

This is basically a convinience handler.

The events must implement serdes DeserializeOwned.

Hint

The handle method gets called on &mut self.

Associated Types

type Event: DeserializeOwned

Required Methods

fn handle(&mut self, events: Vec<Self::Event>) -> TypedProcessingStatus

Execute the processing logic with a deserialized batch of events.

Implementors