Struct evento::Evento

pub struct Evento<E: Engine + Sync + Send, S: StoreEngine + Sync + Send> {
    pub engine: E,
    /* private fields */
}

Fields

engine: E

Implementations

impl<E: Engine + Sync + Send + 'static, S: StoreEngine + Sync + Send + 'static> Evento<E, S>

pub fn new(engine: E, store: EventStore<S>) -> Self

pub fn name<N: Into<String>>(self, name: N) -> Self

pub fn data<V: Send + Sync + 'static>(self, v: V) -> Self

pub fn subscribe(self, s: Subscriber) -> Self

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

pub async fn run(&self, delay: u64) -> Result<Producer<S>, StoreError>

Trait Implementations

impl<E: Clone + Engine + Sync + Send, S: Clone + StoreEngine + Sync + Send> Clone for Evento<E, S>

fn clone(&self) -> Evento<E, S>

Returns a copy of the value.

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

Performs copy-assignment from source.