Struct InProcessEventBus 

pub struct InProcessEventBus { /* private fields */ }

In-process event bus using tokio::sync::broadcast.

Capacity is the broadcast buffer. Slow consumers may lag.

Implementations

impl InProcessEventBus

pub fn new(capacity: usize) -> Arc<Self>

Create a new bus with the given broadcast capacity.

Trait Implementations

impl Debug for InProcessEventBus

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

Formats the value using the given formatter.

impl EventBus for InProcessEventBus

fn publish( &self, topic: &EventTopic, payload: EventPayload, ) -> Pin<Box<dyn Future<Output = Result<(), SdkError>> + Send + '_>>

Publish a payload to a topic.

fn subscribe( &self, _topic: &EventTopic, ) -> Pin<Box<dyn Future<Output = Result<SubscriptionHandle, SdkError>> + Send + '_>>

Subscribe to a topic (exact match or prefix match per impl).