pub struct KernelPort { /* private fields */ }Implementations§
Source§impl KernelPort
impl KernelPort
pub fn drain_commands(&self, limit: usize) -> Vec<CommandEnvelope>
pub fn publish_snapshot(&self, snapshot: ControlSnapshot)
Sourcepub fn publish_events(
&self,
events: impl IntoIterator<Item = ControlEvent>,
) -> PublishReport
pub fn publish_events( &self, events: impl IntoIterator<Item = ControlEvent>, ) -> PublishReport
Slow subscribers are disconnected instead of silently losing ordered control events. Their next receive observes channel disconnection.
Auto Trait Implementations§
impl !Sync for KernelPort
impl Freeze for KernelPort
impl RefUnwindSafe for KernelPort
impl Send for KernelPort
impl Unpin for KernelPort
impl UnsafeUnpin for KernelPort
impl UnwindSafe for KernelPort
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