queue_ext

Trait Waker

Source 
pub trait Waker {
    // Required methods
    fn rx_wake(&self);
    fn tx_park(&self, w: Waker);
    fn close_channel(&self);
    fn is_closed(&self) -> bool;
}

Required Methods§

Source

fn rx_wake(&self)

Source

fn tx_park(&self, w: Waker)

Source

fn close_channel(&self)

Source

fn is_closed(&self) -> bool

Implementors§

Source§

impl<Q, Item, F> Waker for QueueStream<Q, Item, F>