Trait amadeus_core::Source[−][src]

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

type Error: Error[src]

type ParStream: ParallelStream<Item = Result<Self::Item, Self::Error>>[src]

type DistStream: DistributedStream<Item = Result<Self::Item, Self::Error>>[src]

Required methods

fn par_stream(self) -> Self::ParStream[src]

fn dist_stream(self) -> Self::DistStream[src]

Implementors