pub struct CounterCore<T, D, P: Push<BundleCore<T, D>>> { /* private fields */ }
Expand description
A wrapper which updates shared produced
based on the number of records pushed.
Implementations§
source§impl<T, D, P: Push<BundleCore<T, D>>> CounterCore<T, D, P>
impl<T, D, P: Push<BundleCore<T, D>>> CounterCore<T, D, P>
sourcepub fn new(pushee: P) -> CounterCore<T, D, P>
pub fn new(pushee: P) -> CounterCore<T, D, P>
Allocates a new Counter
from a pushee and shared counts.
sourcepub fn produced(&self) -> &Rc<RefCell<ChangeBatch<T>>>
pub fn produced(&self) -> &Rc<RefCell<ChangeBatch<T>>>
A references to shared changes in counts, for cloning or draining.
Trait Implementations§
source§impl<T: Debug, D: Debug, P: Debug + Push<BundleCore<T, D>>> Debug for CounterCore<T, D, P>
impl<T: Debug, D: Debug, P: Debug + Push<BundleCore<T, D>>> Debug for CounterCore<T, D, P>
source§impl<T: Timestamp, D: Container, P> Push<Message<Message<T, D>>> for CounterCore<T, D, P>where
P: Push<BundleCore<T, D>>,
impl<T: Timestamp, D: Container, P> Push<Message<Message<T, D>>> for CounterCore<T, D, P>where
P: Push<BundleCore<T, D>>,
Auto Trait Implementations§
impl<T, D, P> !RefUnwindSafe for CounterCore<T, D, P>
impl<T, D, P> !Send for CounterCore<T, D, P>
impl<T, D, P> !Sync for CounterCore<T, D, P>
impl<T, D, P> Unpin for CounterCore<T, D, P>
impl<T, D, P> !UnwindSafe for CounterCore<T, D, P>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more