Struct Stoppable 

pub struct Stoppable { /* private fields */ }

Shared stop flag passed via Context::stoppable.

Cloneable, thread-safe. Setting it asks the executor to terminate the run loop after the current iteration completes — and, if the handle was bound to a running executor, also wakes the WaitSet immediately.

Implementations

impl Stoppable

pub fn new() -> Self

Create a fresh, un-stopped handle with no wakeup wired. Useful for tests; the executor uses with_waker to bind a notifier.

pub fn stop(&self)

Request stop. Flips the flag (Release) and, if a waker was bound, notifies the WaitSet so it returns from wait_and_process promptly.

pub fn is_stopped(&self) -> bool

Check whether stop has been requested.

Trait Implementations

impl Clone for Stoppable

fn clone(&self) -> Stoppable

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Stoppable

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

Formats the value using the given formatter.

impl Default for Stoppable

fn default() -> Self

Returns the “default value” for a type.

impl Send for Stoppable