Struct ExtensionSlots 

pub struct ExtensionSlots<C, EV, DE> {
    pub command_interceptors: Vec<CommandInterceptor<C, DE>>,
    pub event_listeners: Vec<EventListener<EV>>,
    pub command_taps: Vec<UnboundedSender<C>>,
    pub event_taps: Vec<UnboundedSender<EV>>,
}

Bundle of extension hooks. Reused by every pattern that wants to let users plug in their own actors / sinks at well-known points.

Fields

command_interceptors: Vec<CommandInterceptor<C, DE>>

event_listeners: Vec<EventListener<EV>>

command_taps: Vec<UnboundedSender<C>>

event_taps: Vec<UnboundedSender<EV>>

Implementations

impl<C, EV, DE> ExtensionSlots<C, EV, DE>

pub fn run_interceptors(&self, cmd: &C) -> Result<(), PatternError<DE>>

Run every interceptor; bail on the first rejection.

pub fn notify_listeners(&self, ev: &EV)

Notify every event listener.

impl<C: Clone, EV, DE> ExtensionSlots<C, EV, DE>

pub fn push_command_taps(&mut self, cmd: &C)

Push a command clone to every command tap. Closed receivers are silently pruned.

impl<C, EV: Clone, DE> ExtensionSlots<C, EV, DE>

pub fn push_event_taps(&mut self, ev: &EV)

Push an event clone to every event tap. Closed receivers are silently pruned.

Trait Implementations

impl<C, EV, DE> Clone for ExtensionSlots<C, EV, DE>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C, EV, DE> Default for ExtensionSlots<C, EV, DE>

fn default() -> Self

Returns the “default value” for a type.