Struct MemoryRuntimeStreamAdapter 

pub struct MemoryRuntimeStreamAdapter { /* private fields */ }

In-memory RuntimeStreamAdapter for tests and single-instance setups.

Each RuntimeRoom is backed by a tokio::sync::broadcast channel. Slow consumers receive RuntimeStreamError::Lagged items rather than blocking publishers.

Implementations

impl MemoryRuntimeStreamAdapter

pub fn new() -> Self

Creates an empty adapter.

Trait Implementations

impl Debug for MemoryRuntimeStreamAdapter

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

Formats the value using the given formatter.

impl Default for MemoryRuntimeStreamAdapter

fn default() -> MemoryRuntimeStreamAdapter

Returns the “default value” for a type.

impl RuntimeStreamAdapter for MemoryRuntimeStreamAdapter

fn publish<'life0, 'async_trait>( &'life0 self, room: RuntimeRoom, event: RuntimeEventEnvelope, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeStreamError>> + Send + 'async_trait>>

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

Best-effort fanout of event to all live subscribers of room.

fn subscribe<'life0, 'async_trait>( &'life0 self, room: RuntimeRoom, ) -> Pin<Box<dyn Future<Output = Result<BoxRuntimeEventStream, RuntimeStreamError>> + Send + 'async_trait>>

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

Subscribes to the live event stream for room.