Struct EventBus 

pub struct EventBus { /* private fields */ }

A broadcast-based event bus for the Punch system.

Cloning an EventBus yields a handle to the same underlying channel.

Implementations

impl EventBus

pub fn new() -> Self

Create a new event bus with the default capacity.

pub fn with_capacity(capacity: usize) -> Self

Create a new event bus with a specific channel capacity.

pub fn publish(&self, event: PunchEvent)

Publish an event to all active subscribers.

If there are no subscribers the event is silently dropped.

pub fn publish_payload(&self, payload: EventPayload)

Publish a pre-built EventPayload (useful when you need a custom correlation ID or timestamp).

pub fn subscribe(&self) -> Receiver<EventPayload>

Subscribe to all future events on this bus.

Returns a broadcast::Receiver that will yield every event published after the subscription is created. If the receiver falls behind by more than the channel capacity, older events will be dropped and the receiver will see a broadcast::error::RecvError::Lagged error.

pub fn subscribe_filtered<F>(&self, predicate: F) -> FilteredReceiver<F>

where F: Fn(&PunchEvent) -> bool + Send + 'static,

Subscribe and return only events matching a predicate.

This is a convenience wrapper — filtering happens on the receiver side. For high-throughput scenarios consider filtering inside the subscriber’s own task loop instead.

pub fn subscriber_count(&self) -> usize

Return the current number of active subscribers.

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> EventBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.