Struct StopReceiver 

pub struct StopReceiver { /* private fields */ }

Checked, not blocked on: a Driver owns a single self-contained loop with no downstream dataflow graph to cascade a stop through (unlike crate::pipeline::Pipeline’s control channel, which has to reach every Sink a Queue boundary away before it can call Stop fully handled). So DriverRunner::stop just flips a flag instead of sending something that has to be received and acked — nothing here can reproduce the deadlock that pattern is prone to when a receiver can legitimately go away without ever looping back to check it (see Pipeline’s own control_rx field docs for that history). Callers that need to know run has actually finished watch DriverRunner::bus instead, same convention as Pipeline.

Implementations

impl StopReceiver

pub fn is_stopped(&self) -> bool

Returns whether the owning DriverRunner has requested shutdown.

Trait Implementations

impl Clone for StopReceiver

fn clone(&self) -> StopReceiver

Returns a duplicate of the value.

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

Performs copy-assignment from source.