Type Alias ThreadPuller

pub type ThreadPuller<T> = Puller<T, Puller<T>>;

Thread-local counting channel pull endpoint.

Aliased Type

struct ThreadPuller<T> { /* private fields */ }

Implementations

impl<T, P> Puller<T, P>

where P: Pull<T>,

pub fn new( puller: P, index: usize, events: Rc<RefCell<Vec<usize>>>, ) -> Puller<T, P>

Wraps a puller with a message counter.

Trait Implementations

impl<T, P> Pull<T> for Puller<T, P>

where P: Pull<T>,

fn pull(&mut self) -> &mut Option<T>

Pulls an element and provides the opportunity to take ownership.

fn recv(&mut self) -> Option<T>

Takes an Option<T> and leaves None behind.