Struct InMemoryEventBus 

pub struct InMemoryEventBus { /* private fields */ }

In-memory bus for tests or small products.

Implementations

impl InMemoryEventBus

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

Create a new in-memory bus with the given channel capacity.

Trait Implementations

impl EventBus for InMemoryEventBus

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).