Struct CountSink 

pub struct CountSink<T> { /* private fields */ }

Sink that counts items received.

Example

use grafos_stream::sink::CountSink;
use grafos_stream::stage::Sink;

let mut sink: CountSink<u32> = CountSink::new();
sink.accept(10).unwrap();
sink.accept(20).unwrap();
assert_eq!(sink.count(), 2);

Implementations

impl<T> CountSink<T>

pub fn new() -> Self

Create a count sink initialized to zero.

pub fn count(&self) -> u64

Number of items accepted so far.

Trait Implementations

impl<T> Default for CountSink<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Sink<T> for CountSink<T>

fn accept(&mut self, _item: T) -> Result<(), FabricError>