[−][src]Trait amadeus_core::Destination

pub trait Destination<I> where
    I: DistributedPipe<Self::Item>, {
    type Item;
    type Error: Error;
    type DistSink: DistributedSink<I, Self::Item, Result<(), Self::Error>>;
    fn dist_sink(self) -> Self::DistSink;
}

Associated Types

`type Item`

`type Error: Error`

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

Loading content...

Required methods

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

Loading content...

Implementors

Loading content...