[−][src]Trait amadeus::Destination

pub trait Destination {
    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;
}

Associated Types

`type Item: Data`

`type Error: Error`

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

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

Loading content...

Required methods

`fn par_sink(self) -> Self::ParSink`

`fn dist_sink(self) -> Self::DistSink`

Loading content...

Implementors

Loading content...