Struct EventStreams 

pub struct EventStreams<EVT: Send + Sync + 'static> { /* private fields */ }

Main object which allows to send events and subscribe to them

Implementations

impl<EVT: Send + Sync + 'static> EventStreams<EVT>

pub fn new() -> Self

pub fn count(&self) -> usize

Return number of subscribers

pub fn post_event<EVTSRC: Into<Option<Arc<EventBox>>>>( &self, event: EVT, source: EVTSRC, )

Put event to streams and immediately return

Parameters:

• event - event itself
• source - optional parameter with event which was the cause of event. See Dependent Events section for details

pub fn send_event<EVTSRC: Into<Option<Arc<EventBox>>>>( &self, event: EVT, source: EVTSRC, ) -> SentEvent

Put event to streams and return future whcih blocks until event is handled by all subscribers

Parameters:

• event - event itself
• source - optional parameter with event which was the cause of event. See Dependent Events section for details

pub fn create_event_stream(&self) -> EventStream<EVT>

pub fn clear(&self)

Remove all pending events for all subscribers