Struct evento::Producer

pub struct Producer<S: StoreEngine + Send + Sync> { /* private fields */ }

Implementations

impl<S: StoreEngine + Send + Sync> Producer<S>

pub fn publish<A: Aggregate, I: Into<String>>( &self, id: I, events: Vec<Event>, original_version: i32 ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, StoreError>> + Send + '_>>

pub fn load<A: Aggregate, I: Into<String>>( &self, id: I ) -> Pin<Box<dyn Future<Output = StoreEngineResult<A>> + Send + '_>>

Trait Implementations

impl<S: Clone + StoreEngine + Send + Sync> Clone for Producer<S>

fn clone(&self) -> Producer<S>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.