Struct timely_communication::allocator::counters::Pusher

pub struct Pusher<T, P: Push<T>> { /* private fields */ }

The push half of an intra-thread channel.

Implementations

impl<T, P: Push<T>> Pusher<T, P>

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

Wraps a pusher with a message counter.

Trait Implementations

impl<T, P: Push<T>> Push<T> for Pusher<T, P>

fn push(&mut self, element: &mut Option<T>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.