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