Trait Sink
amadeus_core
pub trait Sink<I> where I: DistributedIteratorMulti<Self::Item>, { type Item; type Error: Error; type DistDest: DistributedReducer<I, Self::Item, Result<(), Self::Error>>; }
type Item
type Error: Error
type DistDest: DistributedReducer<I, Self::Item, Result<(), Self::Error>>