Struct timely_communication::allocator::counters::ArcPusher

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

The push half of an intra-thread channel.

Implementations

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

pub fn new( pusher: P, index: usize, events: Sender<usize>, buzzer: Buzzer, ) -> Self

Wraps a pusher with a message counter.

Trait Implementations

impl<T, P: Push<T>> Push<T> for ArcPusher<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.