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", so this trait is not object safe.

Implementations on Foreign Types§

Source§

impl IntoDistributedStream for String

Source§

impl<'a> IntoDistributedStream for &'a String

Source§

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

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, T> IntoDistributedStream for &'a Option<T>
where T: ProcessSend + 'static + Clone,

Source§

impl<'a, T> IntoDistributedStream for &'a [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 BTreeSet<T>
where T: ProcessSend + 'static + Clone,

Source§

impl<'a, T> IntoDistributedStream for &'a LinkedList<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 Vec<T>
where T: 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<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> IntoDistributedStream for BTreeMap<K, V>
where K: ProcessSend + 'static, V: 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<T> IntoDistributedStream for Option<T>
where T: ProcessSend + 'static,

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

impl<T> IntoDistributedStream for Vec<T>
where T: 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,

Implementors§