Struct EventRouter 

pub struct EventRouter { /* private fields */ }

In-process station event router.

Implementations

impl EventRouter

pub fn new(limits: EventQueueLimits) -> Self

Creates an empty event router.

pub fn register_station(&mut self, station_id: StationId)

Registers a station target queue.

pub fn register_stations(&mut self, stations: &StationSet)

Registers all stations in a set.

pub fn unregister_station(&mut self, station_id: StationId) -> Option<usize>

Unregisters a station queue and returns the number of queued events dropped.

pub fn route( &mut self, event: StationEvent, ) -> Result<PushOutcome, EventRouterError>

Routes an event to its target station queue.

pub fn drain_ready( &mut self, station_id: StationId, current_tick: Tick, ) -> Result<Vec<StationEvent>, EventRouterError>

Drains events whose target_tick is ready for application.

pub fn drain_ready_into( &mut self, station_id: StationId, current_tick: Tick, ready: &mut Vec<StationEvent>, ) -> Result<(), EventRouterError>

Drains ready events into caller-owned storage while retaining its capacity.

pub fn queued_len(&self, station_id: StationId) -> Option<usize>

Returns queued event count for one station.

pub const fn stats(&self) -> EventRouterStats

Returns router statistics.

Trait Implementations

impl Clone for EventRouter

fn clone(&self) -> EventRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventRouter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for EventRouter

fn default() -> Self

Returns the “default value” for a type.