pub struct BroadcastingInjector { /* private fields */ }Expand description
Injector adapter used by relay-device mode: inject once, then mirror the received command to every local stream subscriber.
Implementations§
Source§impl BroadcastingInjector
impl BroadcastingInjector
pub fn new(inner: Arc<dyn Injector>, bus: CommandBus) -> Self
Trait Implementations§
Source§impl Injector for BroadcastingInjector
impl Injector for BroadcastingInjector
Source§fn inject(&self, cmd: &InjectionCommand) -> Result<(), AppError>
fn inject(&self, cmd: &InjectionCommand) -> Result<(), AppError>
Replay one command. A per-command failure is logged by the caller and
does not tear down the daemon.
Source§fn semantic_event(&self, event: &SemanticEvent) -> Result<(), AppError>
fn semantic_event(&self, event: &SemanticEvent) -> Result<(), AppError>
Additive application-event hook. Never fall back to OS injection.
fn supports_events(&self) -> bool
Auto Trait Implementations§
impl Freeze for BroadcastingInjector
impl !RefUnwindSafe for BroadcastingInjector
impl Send for BroadcastingInjector
impl Sync for BroadcastingInjector
impl Unpin for BroadcastingInjector
impl UnsafeUnpin for BroadcastingInjector
impl !UnwindSafe for BroadcastingInjector
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more