Module timely::dataflow::channels::pushers::counter [] [src]

A wrapper which counts the number of records pushed past and updates a shared count map.

Structs

Counter

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