Trait amadeus::IntoDistributedStream

pub trait IntoDistributedStream {
    type DistStream: DistributedStream;
    type Item;
    fn into_dist_stream(self) -> Self::DistStream;

    fn par_stream_mut(
        &mut self
    ) -> <&mut Self as IntoDistributedStream>::DistStream
    where
        &'a mut Self: for<'a> IntoDistributedStream,
    { ... }
    fn dist_stream(&self) -> <&Self as IntoDistributedStream>::DistStream
    where
        &'a Self: for<'a> IntoDistributedStream,
    { ... }
}

Associated Types

type DistStream: DistributedStream

type Item

Required methods

fn into_dist_stream(self) -> Self::DistStream

Provided methods

fn par_stream_mut(&mut self) -> <&mut Self as IntoDistributedStream>::DistStream where
    &'a mut Self: for<'a> IntoDistributedStream, 

fn dist_stream(&self) -> <&Self as IntoDistributedStream>::DistStream where
    &'a Self: for<'a> IntoDistributedStream, 

Implementations on Foreign Types

impl<T> IntoDistributedStream for BTreeSet<T> where
    T: ProcessSend + 'static, 

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

pub fn into_dist_stream(
    self
) -> <BTreeSet<T> as IntoDistributedStream>::DistStream where
    BTreeSet<T>: Sized, 

impl<'a, T> IntoDistributedStream for &'a Vec<T, Global> where
    T: Clone + ProcessSend + 'static, 

type DistStream = IterDistStream<Cloned<Iter<'a, T>>>

type Item = T

pub fn into_dist_stream(
    self
) -> <&'a Vec<T, Global> as IntoDistributedStream>::DistStream where
    &'a Vec<T, Global>: Sized, 

impl<'a, T> IntoDistributedStream for &'a VecDeque<T> where
    T: Clone + ProcessSend + 'static, 

type DistStream = IterDistStream<Cloned<Iter<'a, T>>>

type Item = T

pub fn into_dist_stream(
    self
) -> <&'a VecDeque<T> as IntoDistributedStream>::DistStream where
    &'a VecDeque<T>: Sized, 

impl<T> IntoDistributedStream for BinaryHeap<T> where
    T: Ord + ProcessSend + 'static, 

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

pub fn into_dist_stream(
    self
) -> <BinaryHeap<T> as IntoDistributedStream>::DistStream where
    BinaryHeap<T>: Sized, 

impl<'a, T> IntoDistributedStream for &'a BTreeSet<T> where
    T: Clone + ProcessSend + 'static, 

type DistStream = IterDistStream<Cloned<Iter<'a, T>>>

type Item = T

pub fn into_dist_stream(
    self
) -> <&'a BTreeSet<T> as IntoDistributedStream>::DistStream where
    &'a BTreeSet<T>: Sized, 

impl<'a, T> IntoDistributedStream for &'a [T] where
    T: Clone + ProcessSend + 'static, 

type DistStream = IterDistStream<Cloned<Iter<'a, T>>>

type Item = T

pub fn into_dist_stream(self) -> <&'a [T] as IntoDistributedStream>::DistStream where
    &'a [T]: Sized, 

impl<Idx> IntoDistributedStream for RangeFrom<Idx> where
    RangeFrom<Idx>: Iterator,
    <RangeFrom<Idx> as Iterator>::Item: ProcessSend,
    <RangeFrom<Idx> as Iterator>::Item: 'static, 

type DistStream = IterDistStream<RangeFrom<Idx>>

type Item = <RangeFrom<Idx> as Iterator>::Item

pub fn into_dist_stream(
    self
) -> <RangeFrom<Idx> as IntoDistributedStream>::DistStream where
    RangeFrom<Idx>: Sized, 

impl<K, V, S> IntoDistributedStream for HashMap<K, V, S> where
    K: Eq + Hash + ProcessSend + 'static,
    V: ProcessSend + 'static,
    S: BuildHasher + Default, 

type DistStream = IterDistStream<IntoIter<K, V>>

type Item = (K, V)

pub fn into_dist_stream(
    self
) -> <HashMap<K, V, S> as IntoDistributedStream>::DistStream where
    HashMap<K, V, S>: Sized, 

impl<Idx> IntoDistributedStream for Range<Idx> where
    Range<Idx>: Iterator,
    <Range<Idx> as Iterator>::Item: ProcessSend,
    <Range<Idx> as Iterator>::Item: 'static, 

type DistStream = IterDistStream<Range<Idx>>

type Item = <Range<Idx> as Iterator>::Item

pub fn into_dist_stream(
    self
) -> <Range<Idx> as IntoDistributedStream>::DistStream where
    Range<Idx>: Sized, 

impl<K, V> IntoDistributedStream for BTreeMap<K, V> where
    K: ProcessSend + 'static,
    V: ProcessSend + 'static, 

type DistStream = IterDistStream<IntoIter<K, V>>

type Item = (K, V)

pub fn into_dist_stream(
    self
) -> <BTreeMap<K, V> as IntoDistributedStream>::DistStream where
    BTreeMap<K, V>: Sized, 

impl<T> IntoDistributedStream for Option<T> where
    T: ProcessSend + 'static, 

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

pub fn into_dist_stream(
    self
) -> <Option<T> as IntoDistributedStream>::DistStream where
    Option<T>: Sized, 

impl<T> IntoDistributedStream for LinkedList<T> where
    T: ProcessSend + 'static, 

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

pub fn into_dist_stream(
    self
) -> <LinkedList<T> as IntoDistributedStream>::DistStream where
    LinkedList<T>: Sized, 

impl<T> IntoDistributedStream for Vec<T, Global> where
    T: ProcessSend + 'static, 

type DistStream = IterDistStream<IntoIter<T, Global>>

type Item = T

pub fn into_dist_stream(
    self
) -> <Vec<T, Global> as IntoDistributedStream>::DistStream where
    Vec<T, Global>: Sized, 

impl<T> IntoDistributedStream for VecDeque<T> where
    T: ProcessSend + 'static, 

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

pub fn into_dist_stream(
    self
) -> <VecDeque<T> as IntoDistributedStream>::DistStream where
    VecDeque<T>: Sized, 

impl IntoDistributedStream for String

type DistStream = IterDistStream<OwnedChars>

type Item = char

pub fn into_dist_stream(self) -> <String as IntoDistributedStream>::DistStream where
    String: Sized, 

impl<'a, T, S> IntoDistributedStream for &'a HashSet<T, S> where
    T: Clone + Eq + Hash + ProcessSend + 'static,
    S: BuildHasher + Default, 

type DistStream = IterDistStream<Cloned<Iter<'a, T>>>

type Item = T

pub fn into_dist_stream(
    self
) -> <&'a HashSet<T, S> as IntoDistributedStream>::DistStream where
    &'a HashSet<T, S>: Sized, 

impl<'a> IntoDistributedStream for &'a String

type DistStream = IterDistStream<Chars<'a>>

type Item = char

pub fn into_dist_stream(
    self
) -> <&'a String as IntoDistributedStream>::DistStream where
    &'a String: Sized, 

impl<T, S> IntoDistributedStream for HashSet<T, S> where
    T: Eq + Hash + ProcessSend + 'static,
    S: BuildHasher + Default, 

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

pub fn into_dist_stream(
    self
) -> <HashSet<T, S> as IntoDistributedStream>::DistStream where
    HashSet<T, S>: Sized, 

impl<'a, T> IntoDistributedStream for &'a BinaryHeap<T> where
    T: Ord + Clone + ProcessSend + 'static, 

type DistStream = IterDistStream<Cloned<Iter<'a, T>>>

type Item = T

pub fn into_dist_stream(
    self
) -> <&'a BinaryHeap<T> as IntoDistributedStream>::DistStream where
    &'a BinaryHeap<T>: Sized, 

impl<'a, T, E> IntoDistributedStream for &'a Result<T, E> where
    T: Clone + ProcessSend + 'static, 

type DistStream = IterDistStream<Cloned<Iter<'a, T>>>

type Item = T

pub fn into_dist_stream(
    self
) -> <&'a Result<T, E> as IntoDistributedStream>::DistStream where
    &'a Result<T, E>: Sized, 

impl<'a, K, V, S> IntoDistributedStream for &'a HashMap<K, V, S> where
    K: Clone + Eq + Hash + ProcessSend + 'static,
    V: Clone + ProcessSend + 'static,
    S: BuildHasher + Default, 

type DistStream = IterDistStream<TupleCloned<Iter<'a, K, V>>>

type Item = (K, V)

pub fn into_dist_stream(
    self
) -> <&'a HashMap<K, V, S> as IntoDistributedStream>::DistStream where
    &'a HashMap<K, V, S>: Sized, 

impl<T> IntoDistributedStream for [T] where
    T: ProcessSend + 'static, 

type DistStream = Never

type Item = Never

pub fn into_dist_stream(self) -> <[T] as IntoDistributedStream>::DistStream where
    [T]: Sized, 

impl<'a, T> IntoDistributedStream for &'a LinkedList<T> where
    T: Clone + ProcessSend + 'static, 

type DistStream = IterDistStream<Cloned<Iter<'a, T>>>

type Item = T

pub fn into_dist_stream(
    self
) -> <&'a LinkedList<T> as IntoDistributedStream>::DistStream where
    &'a LinkedList<T>: Sized, 

impl<'a, T> IntoDistributedStream for &'a Option<T> where
    T: Clone + ProcessSend + 'static, 

type DistStream = IterDistStream<Cloned<Iter<'a, T>>>

type Item = T

pub fn into_dist_stream(
    self
) -> <&'a Option<T> as IntoDistributedStream>::DistStream where
    &'a Option<T>: Sized, 

impl<Idx> IntoDistributedStream for RangeInclusive<Idx> where
    RangeInclusive<Idx>: Iterator,
    <RangeInclusive<Idx> as Iterator>::Item: ProcessSend,
    <RangeInclusive<Idx> as Iterator>::Item: 'static, 

type DistStream = IterDistStream<RangeInclusive<Idx>>

type Item = <RangeInclusive<Idx> as Iterator>::Item

pub fn into_dist_stream(
    self
) -> <RangeInclusive<Idx> as IntoDistributedStream>::DistStream where
    RangeInclusive<Idx>: Sized, 

impl<T, E> IntoDistributedStream for Result<T, E> where
    T: ProcessSend + 'static, 

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

pub fn into_dist_stream(
    self
) -> <Result<T, E> as IntoDistributedStream>::DistStream where
    Result<T, E>: Sized, 

impl<'a, K, V> IntoDistributedStream for &'a BTreeMap<K, V> where
    K: Clone + ProcessSend + 'static,
    V: Clone + ProcessSend + 'static, 

type DistStream = IterDistStream<TupleCloned<Iter<'a, K, V>>>

type Item = (K, V)

pub fn into_dist_stream(
    self
) -> <&'a BTreeMap<K, V> as IntoDistributedStream>::DistStream where
    &'a BTreeMap<K, V>: Sized, 

Implementors

impl<T> IntoDistributedStream for T where
    T: DistributedStream, 

type DistStream = T

type Item = <T as DistributedStream>::Item

pub fn into_dist_stream(self) -> <T as IntoDistributedStream>::DistStream