Enum CommandEffect 

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

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

Variants

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

Reply(Reply)

Reject(Error)

Implementations

impl<E, Reply, Error> CommandEffect<E, Reply, Error>

where E: EventSourced,

pub fn emit_and_reply( event: E::Event, 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 reply(reply: Reply) -> Self

Reply with the given value without emitting any event.

pub fn reject(error: Error) -> Self

Reject this command with the given error.

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

where E: EventSourced,

pub fn emit(event: E::Event) -> Self

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