Trait Destination
amadeus::source
pub trait Destination: Clone + Debug { type Item: Data; type Error: Error; type ParSink: ParallelSink<Self::Item, Output = Result<(), Self::Error>>; type DistSink: DistributedSink<Self::Item, Output = Result<(), Self::Error>>; fn par_sink(self) -> Self::ParSink; fn dist_sink(self) -> Self::DistSink; }
type Item: Data
type Error: Error
type ParSink: ParallelSink<Self::Item, Output = Result<(), Self::Error>>
type DistSink: DistributedSink<Self::Item, Output = Result<(), Self::Error>>
fn par_sink(self) -> Self::ParSink
fn dist_sink(self) -> Self::DistSink