Struct TypedBus 

pub struct TypedBus { /* private fields */ }

Typed in-Node event bus. Carries published events from one poll cycle to the next; the engine’s bus-routing pass drains the queue and routes to subscribed NodeSiteIds.

Bounded by NodeConfig.bus_capacity (default 1024). When a publish would exceed the cap, the oldest event is FIFO-dropped and a counter increments. The routing pass reads the counter and emits InfraEvent::BusOverflow { count } so the host sees the loss.

Implementations

impl TypedBus

pub fn new() -> TypedBus

Construct a fresh empty bus with no cap.

pub fn with_cap(cap: Option<usize>) -> TypedBus

Construct a fresh empty bus with the given FIFO-drop cap.

pub fn set_cap(&mut self, cap: Option<usize>)

Set the FIFO-drop cap. None removes the cap.

pub fn publish(&mut self, event: NodeEvent)

Publish an event. The engine’s bus-routing pass delivers published events to subscribed Components in the next poll cycle.

pub fn drain(&mut self) -> Vec<NodeEvent>

Drain all queued events. Called by the engine’s bus-routing pass.

pub fn take_dropped_count(&mut self) -> usize

Read + reset the count of FIFO-dropped events since the last call. Returns 0 when no drops occurred.

pub fn is_empty(&self) -> bool

true when the bus has no queued events.

pub fn len(&self) -> usize

Number of queued events.

Trait Implementations

impl Default for TypedBus

fn default() -> TypedBus

Returns the “default value” for a type.