Struct ControlWaker 

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

Wakes a coordinated source’s control-plane wait.

Cheap to clone and safe to signal from any thread — including a pipeline thread on the data path, because wake never blocks. The channel behind it holds a single slot, so a burst of signals collapses into one wakeup, and a signal that lands while the driver is between its check and its park is buffered rather than lost.

Signal it for anything the driver would otherwise only notice between waits: a backend with events ready, a lane reaching end-of-input, a lane reporting poison.

Implementations

impl ControlWaker

pub fn inert() -> ControlWaker

A waker attached to nothing: wake is a no-op. For unit tests that construct a lane without a driver, and for sources that have no control-plane park to interrupt.

pub fn wake(&self)

Wake the driver if it is parked, or make its next park return immediately. Never blocks.

Trait Implementations

impl Clone for ControlWaker

fn clone(&self) -> ControlWaker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ControlWaker

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

Formats the value using the given formatter.