Struct timely_communication::allocator::counters::ArcPusher

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

The push half of an intra-thread channel.

Methods

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

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