Struct CapacityWake 

pub struct CapacityWake { /* private fields */ }

Capacity wake controller

Implementations

impl CapacityWake

pub fn new(outer_signal: Arc<AtomicBool>) -> Self

Create a new capacity wake with the given outer signal.

pub fn get_signal(&self) -> CapacitySignal

Get the capacity signal. When triggered (from either outer abort or wake() call), the poll loop should re-check for work.

pub fn wake(&self)

Wake up the capacity wait. This causes get_signal() to return a triggered signal, and re-arms for the next wait.

pub fn is_outer_aborted(&self) -> bool

Check if the outer signal has been triggered