Trait amadeus::Destination

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

Associated Types

type Item: Data

type Error: Error

type ParSink: ParallelSink<Self::Item, Done = Result<(), Self::Error>>

type DistSink: DistributedSink<Self::Item, Done = Result<(), Self::Error>>

Required methods

fn par_sink(self) -> Self::ParSink

fn dist_sink(self) -> Self::DistSink

Implementors