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