Skip to main content

IntoDistributedStream

Trait IntoDistributedStream 

Source
pub trait IntoDistributedStream {
    type DistStream: DistributedStream<Item = Self::Item>;
    type Item;

    // Required method
    fn into_dist_stream(self) -> Self::DistStream
       where Self: Sized;

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

Required Associated Types§

Required Methods§

Source

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

Provided Methods§

Source

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

Source

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

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types§

Source§

impl IntoDistributedStream for String

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

impl<'a> IntoDistributedStream for &'a String

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Implementors§