Struct Counter

pub struct Counter<T, P> { /* private fields */ }

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

Implementations

impl<T, P> Counter<T, P>

where T: Ord + Clone + 'static,

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

Allocates a new Counter from a pushee and shared counts.

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

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

pub fn give<C: Container>(&mut self, time: T, container: &mut C)

where P: Push<Message<T, C>>,

Ships a time and a container.

This is not a validated capability, and this method should not be used without great care. Ideally, users would not have direct access to a Counter, and preventing this is the way to uphold invariants.

Trait Implementations

impl<T: Debug, P: Debug> Debug for Counter<T, P>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Clone + Ord, C: Accountable, P> Push<Message<T, C>> for Counter<T, P>

where P: Push<Message<T, C>>,

fn push(&mut self, message: &mut Option<Message<T, C>>)

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.