IntoParallelStream

amadeus_core::into_par_stream

Trait IntoParallelStream

pub trait IntoParallelStream {
    type ParStream: ParallelStream<Item = Self::Item>;
    type Item;

    // Required method
    fn into_par_stream(self) -> Self::ParStream
       where Self: Sized;

    // Provided methods
    fn par_stream_mut(&mut self) -> <&mut Self as IntoParallelStream>::ParStream
       where for<'a> &'a mut Self: IntoParallelStream { ... }
    fn par_stream(&self) -> <&Self as IntoParallelStream>::ParStream
       where for<'a> &'a Self: IntoParallelStream { ... }
}

Required Associated Types§

type ParStream: ParallelStream<Item = Self::Item>

type Item

Required Methods§

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

Provided Methods§

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

fn par_stream(&self) -> <&Self as IntoParallelStream>::ParStream
where for<'a> &'a Self: IntoParallelStream,

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

impl IntoParallelStream for String

type ParStream = IterParStream<OwnedChars>

type Item = char

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<'a> IntoParallelStream for &'a String

type ParStream = IterParStream<Chars<'a>>

type Item = char

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

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

type ParStream = IterParStream<TupleCloned<Iter<'a, K, V>>>

type Item = (K, V)

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

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

type ParStream = IterParStream<TupleCloned<Iter<'a, K, V>>>

type Item = (K, V)

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<'a, T> IntoParallelStream for &'a Option<T>
where T: Send + 'static + Clone,

type ParStream = IterParStream<Cloned<Iter<'a, T>>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

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

type ParStream = IterParStream<Cloned<Iter<'a, T>>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

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

type ParStream = IterParStream<Cloned<Iter<'a, T>>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<'a, T> IntoParallelStream for &'a BTreeSet<T>
where T: Send + 'static + Clone,

type ParStream = IterParStream<Cloned<Iter<'a, T>>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<'a, T> IntoParallelStream for &'a LinkedList<T>
where T: Send + 'static + Clone,

type ParStream = IterParStream<Cloned<Iter<'a, T>>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<'a, T> IntoParallelStream for &'a VecDeque<T>
where T: Send + 'static + Clone,

type ParStream = IterParStream<Cloned<Iter<'a, T>>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<'a, T> IntoParallelStream for &'a Vec<T>
where T: Send + 'static + Clone,

type ParStream = IterParStream<Cloned<Iter<'a, T>>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

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

type ParStream = IterParStream<Cloned<Iter<'a, T>>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

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

type ParStream = IterParStream<Cloned<Iter<'a, T>>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<Idx> IntoParallelStream for Range<Idx>
where Self: Iterator, <Self as Iterator>::Item: Send + 'static,

type ParStream = IterParStream<Range<Idx>>

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

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<Idx> IntoParallelStream for RangeFrom<Idx>
where Self: Iterator, <Self as Iterator>::Item: Send + 'static,

type ParStream = IterParStream<RangeFrom<Idx>>

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

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<Idx> IntoParallelStream for RangeInclusive<Idx>
where Self: Iterator, <Self as Iterator>::Item: Send + 'static,

type ParStream = IterParStream<RangeInclusive<Idx>>

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

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<K, V> IntoParallelStream for BTreeMap<K, V>
where K: Send + 'static, V: Send + 'static,

type ParStream = IterParStream<IntoIter<K, V>>

type Item = (K, V)

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

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

type ParStream = IterParStream<IntoIter<K, V>>

type Item = (K, V)

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<T> IntoParallelStream for Option<T>
where T: Send + 'static,

type ParStream = IterParStream<IntoIter<T>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<T> IntoParallelStream for [T]
where T: Send + 'static,

type ParStream = Never

type Item = Never

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<T> IntoParallelStream for BinaryHeap<T>
where T: Send + 'static + Ord,

type ParStream = IterParStream<IntoIter<T>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<T> IntoParallelStream for BTreeSet<T>
where T: Send + 'static,

type ParStream = IterParStream<IntoIter<T>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<T> IntoParallelStream for LinkedList<T>
where T: Send + 'static,

type ParStream = IterParStream<IntoIter<T>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<T> IntoParallelStream for VecDeque<T>
where T: Send + 'static,

type ParStream = IterParStream<IntoIter<T>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<T> IntoParallelStream for Vec<T>
where T: Send + 'static,

type ParStream = IterParStream<IntoIter<T>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

impl<T, E> IntoParallelStream for Result<T, E>
where T: Send + 'static,

type ParStream = IterParStream<IntoIter<T>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

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

type ParStream = IterParStream<IntoIter<T>>

type Item = T

fn into_par_stream(self) -> Self::ParStream
where Self: Sized,

Implementors§

impl<T: ParallelStream> IntoParallelStream for T

type ParStream = T

type Item = <T as ParallelStream>::Item