Struct StopSignal 

pub struct StopSignal { /* private fields */ }

Signal for stopping a subscription.

When the runtime stops a subscription, it sets this signal. The subscription should check it periodically and exit its run loop when set.

Implementations

impl StopSignal

pub fn is_stopped(&self) -> bool

Check if the stop signal has been triggered.

pub fn wait_timeout(&self, duration: Duration) -> bool

Wait for either the stop signal or a timeout.

Returns true if stopped, false if timed out. Blocks the thread efficiently using a condition variable. Handles spurious wakeups by looping until condition met or timeout expired.

Trait Implementations

impl Clone for StopSignal

fn clone(&self) -> StopSignal

Returns a duplicate of the value.

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

Performs copy-assignment from source.