Struct InMemorySignalBus 

pub struct InMemorySignalBus { /* private fields */ }

In-memory signal bus using tokio broadcast channels

Suitable for desktop apps and testing (no external dependencies). Signals are best-effort and may be lost if no receivers are subscribed.

Implementations

impl InMemorySignalBus

pub fn new(capacity: usize) -> Self

Create a new in-memory signal bus with the specified channel capacity

pub fn default() -> Self

Create a new in-memory signal bus with default capacity (1024)

Trait Implementations

impl SignalBus for InMemorySignalBus

fn emit<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, channel: &'life1 str, signal: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Emit a signal to a channel (best-effort, may be ignored)

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, channel: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<SignalReceiver<Vec<u8>>>> + Send + 'async_trait>>

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

Subscribe to a channel, returns a receiver for signals

fn unsubscribe<'life0, 'life1, 'async_trait>( &'life0 self, _channel: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Unsubscribe from a channel