Enum eventsourced::CmdEffect

pub enum CmdEffect<E, Reply, Error>
where
    E: EventSourced,
{
    EmitAndReply(E::Evt, Box<dyn FnOnce(&E) -> Reply + Send + Sync>),
    Reject(Error),
}

The result of handling a command, either emitting an event and replying or rejecting the command.

Variants

EmitAndReply(E::Evt, Box<dyn FnOnce(&E) -> Reply + Send + Sync>)

Reject(Error)

Implementations

impl<E, Reply, Error> CmdEffect<E, Reply, Error>

where E: EventSourced,

pub fn emit_and_reply( evt: E::Evt, make_reply: impl FnOnce(&E) -> Reply + Send + Sync + 'static ) -> Self

Emit the given event, persist it, and after applying it to the state, use the given function to create a reply. The new state is passed to the function after applying the event.

pub fn reject(error: Error) -> Self

Reject this command with the given error.

impl<E, Error> CmdEffect<E, (), Error>

where E: EventSourced,

pub fn emit(evt: E::Evt) -> Self

Persist the given event (and don’t give a reply for Cmds with Reply = ()).