Struct MailboxLiveControlSource 

pub struct MailboxLiveControlSource(/* private fields */);

Adapter exposing any MailboxStore as a runtime LiveRunCommandSource.

The runtime consumes live commands through LiveRunCommandSource (defined in runtime-contract); the mailbox store is the durable source of those commands. With MailboxStore now living in server-contract, a blanket impl<T: MailboxStore> LiveRunCommandSource for T would violate the orphan rule (foreign trait over a generic type), so this concrete wrapper provides the bridge instead.

Implementations

impl MailboxLiveControlSource

pub fn new(store: Arc<dyn MailboxStore>) -> MailboxLiveControlSource

Trait Implementations

impl LiveRunCommandSource for MailboxLiveControlSource

fn open_live_channel_for<'life0, 'life1, 'async_trait>( &'life0 self, target: &'life1 LiveRunTarget, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = LiveRunCommandEntry> + Send>>, LiveControlError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MailboxLiveControlSource: 'async_trait,