Struct TensorEventBusV2 

pub struct TensorEventBusV2 {
    pub subscriptions: Vec<Subscription>,
    pub dead_letters: Vec<TensorEvent>,
    pub stats: BusStats,
    pub next_sub_id: u64,
}

Typed in-process event bus for TensorLogic events.

Events are published synchronously and fanned out to all matching subscriptions in descending priority order. Each subscription maintains a bounded queue; events that overflow the queue are counted as dropped. Events that match no subscription are collected in the dead-letter queue.

Fields

subscriptions: Vec<Subscription>

Active subscriptions, kept sorted by priority descending.

dead_letters: Vec<TensorEvent>

Events that were not delivered to any subscriber.

stats: BusStats

Bus-level statistics.

next_sub_id: u64

Monotonically increasing counter used to assign subscription IDs.

Implementations

impl TensorEventBusV2

pub fn new() -> Self

Creates a new, empty event bus.

pub fn subscribe( &mut self, filter: EventFilter, priority: u32, max_queue_size: usize, ) -> u64

Registers a new subscription and returns its unique identifier.

The internal subscription list is re-sorted after each registration so that publish can iterate in priority order without extra work.

pub fn unsubscribe(&mut self, sub_id: u64) -> bool

Removes the subscription identified by sub_id.

Returns true if the subscription existed and was removed.

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

Publishes an event to all matching subscriptions.

Subscriptions are visited in descending priority order. For each subscription whose filter matches:

• If the queue is not full, the event is cloned and enqueued; delivered and stats.total_delivered are incremented.
• If the queue is full, the event is not enqueued; dropped and stats.total_dropped are incremented.

If no subscription accepted the event it is moved to dead_letters.

pub fn drain(&mut self, sub_id: u64) -> Vec<TensorEvent>

Drains and returns all queued events for the subscription identified by sub_id.

Returns an empty Vec if the subscription does not exist or has no pending events.

pub fn stats(&self) -> &BusStats

Returns a reference to the current bus statistics.

Trait Implementations

impl Debug for TensorEventBusV2

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

Formats the value using the given formatter.

impl Default for TensorEventBusV2

fn default() -> Self

Returns the “default value” for a type.