Struct Valve

pub struct Valve {
    paused: Arc<AtomicBool>,
    waker: Arc<Mutex<Option<Waker>>>,
}

A valve is a handle that can control the Pausable stream.

Fields

paused: Arc<AtomicBool>

waker: Arc<Mutex<Option<Waker>>>

Implementations

impl Valve

pub fn pause(&self)

Pause the stream controlled by the valve.

pub fn resume(&self)

Resume the stream controlled by the valve.

Trait Implementations

impl Clone for Valve

fn clone(&self) -> Valve

Returns a duplicate of the value.

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

Performs copy-assignment from source.