Skip to main content

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".

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, 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, 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, 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<'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 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 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 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 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> 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 [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> IntoParallelStream for &'a String

type ParStream = IterParStream<Chars<'a>>

type Item = char

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, 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<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<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,

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 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 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 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 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> 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 [T]
where T: Send + 'static,

type ParStream = Never

type Item = Never

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