Struct ChannelEventSource 

pub struct ChannelEventSource<Event> { /* private fields */ }

A channel-based event source that receives events from a Tokio MPSC channel

Implementations

impl<Event> ChannelEventSource<Event>

where Event: Send + 'static,

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

Create a new channel event source with a default ID

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

Create a new channel event source with a specific ID

Trait Implementations

impl<Event, Context, Action> EventDrivenNode<Event, Context, Action> for ChannelEventSource<Event>

where Event: Send + 'static, Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Default,

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