Trait amadeus_core::into_par_stream::IntoDistributedStream

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

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

Associated Types

type DistStream: DistributedStream<Item = Self::Item>

type Item

Loading content...

Required methods

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

Loading content...

Provided methods

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

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

Loading content...

Implementations on Foreign Types

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

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: 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

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: 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)

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = (K, V)

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: 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)

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = (K, V)

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

impl IntoDistributedStream for String

type DistStream = IterDistStream<IntoChars>

type Item = char

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

impl<'a> IntoDistributedStream for &'a String

type DistStream = IterDistStream<Chars<'a>>

type Item = char

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = IterDistStream<IntoIter<T>>

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = IterDistStream<Self>

type Item = Self::Item

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = IterDistStream<Self>

type Item = Self::Item

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = IterDistStream<Self>

type Item = Self::Item

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

type DistStream = Never

type Item = Never

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

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

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

type Item = T

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

Loading content...

Implementors

impl<T: DistributedStream> IntoDistributedStream for T

type DistStream = Self

type Item = Self::Item

fn into_dist_stream(self) -> Self::DistStream where
    Self: Sized, 

Loading content...