Struct BroadcastBus 

pub struct BroadcastBus<E> { /* private fields */ }

A typed publish/subscribe bus that broadcasts each event to all subscribers.

Every handle can both publish and receive. Use subscribe to add an independent consumer; an event published after a handle subscribes is delivered to it. A subscriber only sees events published after it subscribed, mirroring a live pub/sub channel.

Examples

use pamoja_core::EventBus;
use pamoja_bus::BroadcastBus;

let bus = BroadcastBus::new(16);
let mut subscriber = bus.subscribe();
bus.publish("reading").await?;
assert_eq!(subscriber.next_event().await?, Some("reading"));

Implementations

impl<E: Clone> BroadcastBus<E>

pub fn new(capacity: usize) -> Self

Creates a bus buffering up to capacity unread events per subscriber.

Arguments

• capacity - the per-subscriber buffer depth; a subscriber further behind than this drops the events it missed. Values below one are raised to one.

Returns

A bus with one handle that can publish and receive.

pub fn subscribe(&self) -> Self

Creates another handle to the same bus with its own independent subscription.

Returns

A handle that receives events published after this call and can also publish.

Trait Implementations

impl<E: Clone> EventBus for BroadcastBus<E>

type Event = E

The event type carried by this bus.

async fn publish(&self, event: Self::Event) -> Result<()>

Publishes an event to every current subscriber.

async fn next_event(&mut self) -> Result<Option<Self::Event>>

Awaits the next event for this subscriber.