Trait Sink 

pub trait Sink<T> {
    // Required method
    fn accept(&mut self, item: T) -> Result<(), FabricError>;
}

Consumes items (terminal stage).

Required Methods

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

Implementors

impl<T> Sink<T> for CollectSink<T>

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

impl<T, F: FnMut(T)> Sink<T> for FnSink<T, F>