Struct timely_communication::allocator::counters::Puller

pub struct Puller<T, P: Pull<T>> { /* private fields */ }

The pull half of an intra-thread channel.

Implementations

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

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

Wraps a puller with a message counter.

Trait Implementations

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

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.