Struct timely::dataflow::channels::pushers::counter::Counter

pub struct Counter<T: Ord, D, P: Push<(T, Content<D>)>> { /* fields omitted */ }

A wrapper which updates shared produced based on the number of records pushed.

Methods

impl<T, D, P: Push<(T, Content<D>)>> Counter<T, D, P> where
    T: Ord + Clone + 'static, 

fn new(pushee: P) -> Counter<T, D, P>

Allocates a new Counter from a pushee and shared counts.

fn produced(&self) -> &Rc<RefCell<ChangeBatch<T>>>

A references to shared changes in counts, for cloning or draining.

Trait Implementations

impl<T: Ord, D, P: Push<(T, Content<D>)>> Push<(T, Content<D>)> for Counter<T, D, P> where
    T: Eq + Clone + 'static, 

fn push(&mut self, message: &mut Option<(T, Content<D>)>)

Pushes element and provides 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.