[−][src]Trait amadeus::Source

pub trait Source {
    type Item: Data;
    type Error: Error;
    type DistStream: DistributedStream<Item = Result<Self::Item, Self::Error>>;
    fn dist_stream(self) -> Self::DistStream;
}

Associated Types

type Item: Data

type Error: Error

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

Loading content...

Required methods

fn dist_stream(self) -> Self::DistStream

Loading content...

Implementors

impl Source for Cloudfront[src]

type Item = CloudfrontRow

type Error = Self::Error

type DistStream = IntoIter<Self::DistStream, Self::Item>

impl Source for CommonCrawl[src]

type Item = Webpage<'static>

type Error = Self::Error

type DistStream = IntoIter<Self::DistStream, Self::Item>

impl<File, Row> Source for Csv<File, Row> where
    File: File,
    Row: Data, [src]

type Item = Self::Item

type Error = Self::Error

type DistStream = Self::DistStream

impl<File, Row> Source for Json<File, Row> where
    File: File,
    Row: Data, [src]

type Item = Self::Item

type Error = Self::Error

type DistStream = Self::DistStream

impl<Row> Source for Postgres<Row> where
    Row: Data, [src]

type Item = Self::Item

type Error = Self::Error

type DistStream = Self::DistStream

Loading content...