Struct timely_communication::allocator::counters::Pusher

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

The push half of an intra-thread channel.

Methods

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

pub fn new(
    pusher: P,
    index: usize,
    events: Rc<RefCell<VecDeque<(usize, Event)>>>
) -> 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.