[][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...