Struct InMemoryDriver 

pub struct InMemoryDriver { /* private fields */ }

Simple in-process broadcast driver backed by a Tokio broadcast channel.

Useful in tests and single-process development servers. Subscribe to InMemoryDriver::subscribe to receive events.

Implementations

impl InMemoryDriver

pub fn new() -> Self

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

Subscribe to all events emitted through this driver.

Trait Implementations

impl BroadcastDriver for InMemoryDriver

fn broadcast<'life0, 'async_trait>( &'life0 self, event: BroadcastEvent, ) -> Pin<Box<dyn Future<Output = Result<(), BroadcastError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl Default for InMemoryDriver

fn default() -> Self

Returns the “default value” for a type.