Struct EventProcessor 

pub struct EventProcessor<Event, Context, Action, F>
where
    Event: Send + 'static,
    Context: Send + Sync + 'static,
    Action: ActionType + Send + Sync + 'static + Default,
    F: Fn(Event, &mut Context) -> Result<Action, FloxideError> + Send + Sync + 'static,
{ /* private fields */ }

An event processor that applies a function to each event

Implementations

impl<Event, Context, Action, F> EventProcessor<Event, Context, Action, F>

where Event: Send + 'static, Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Default, F: Fn(Event, &mut Context) -> Result<Action, FloxideError> + Send + Sync + 'static,

pub fn new(capacity: usize, processor: F) -> (Self, Sender<Event>)

Create a new event processor with a default ID

pub fn with_id( capacity: usize, id: impl Into<String>, processor: F, ) -> (Self, Sender<Event>)

Create a new event processor with a specific ID

Trait Implementations

impl<Event, Context, Action, F> EventDrivenNode<Event, Context, Action> for EventProcessor<Event, Context, Action, F>

where Event: Send + 'static, Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Default, F: Fn(Event, &mut Context) -> Result<Action, FloxideError> + Send + Sync + 'static,

fn wait_for_event<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Event, FloxideError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Wait for an external event to occur

fn process_event<'life0, 'life1, 'async_trait>( &'life0 self, event: Event, ctx: &'life1 mut Context, ) -> Pin<Box<dyn Future<Output = Result<Action, FloxideError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process the received event and update context

fn id(&self) -> NodeId

Get the node’s unique identifier