pub trait EventProcessor {
// Required methods
fn process_next(
&mut self,
message: RecordEvent,
) -> impl Future<Output = Result<()>>;
fn finalize(&mut self) -> impl Future<Output = Result<()>>;
}Expand description
Represents an event processor. This should realistically be able to abstract over different options: local storage, remote server saving.
Required Methods§
fn process_next( &mut self, message: RecordEvent, ) -> impl Future<Output = Result<()>>
fn finalize(&mut self) -> impl Future<Output = Result<()>>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.