[−][src]Trait amadeus_core::Source

pub trait Source: Clone + Debug {
    type Item;
    type Error: Error;
    type ParStream: ParallelStream<Item = Result<Self::Item, Self::Error>>;
    type DistStream: DistributedStream<Item = Result<Self::Item, Self::Error>>;
    fn par_stream(self) -> Self::ParStream;
    fn dist_stream(self) -> Self::DistStream;
}

Associated Types

`type Item`

`type Error: Error`

`type ParStream: ParallelStream<Item = Result<Self::Item, Self::Error>>`

`type DistStream: DistributedStream<Item = Result<Self::Item, Self::Error>>`

Loading content...

Required methods

`fn par_stream(self) -> Self::ParStream`

`fn dist_stream(self) -> Self::DistStream`

Loading content...

Implementors

Loading content...