Trait FromParallelStream 

pub trait FromParallelStream<T>: Sized {
    type ReduceA: ReducerSend<T> + Clone + Send;
    type ReduceC: Reducer<<Self::ReduceA as ReducerSend<T>>::Done, Done = Self>;

    // Required method
    fn reducers() -> (Self::ReduceA, Self::ReduceC);
}

Required Associated Types

type ReduceA: ReducerSend<T> + Clone + Send

type ReduceC: Reducer<<Self::ReduceA as ReducerSend<T>>::Done, Done = Self>

Required Methods

fn reducers() -> (Self::ReduceA, Self::ReduceC)

Dyn Compatibility

This trait is not dyn compatible.

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

Implementations on Foreign Types

impl FromParallelStream<()> for ()

type ReduceA = PushReducer<()>

type ReduceC = PushReducer<()>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl FromParallelStream<String> for String

type ReduceA = PushReducer<String>

type ReduceC = PushReducer<String>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl FromParallelStream<char> for String

type ReduceA = PushReducer<char, String>

type ReduceC = PushReducer<String>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<K, V, S> FromParallelStream<(K, V)> for HashMap<K, V, S>

where K: Eq + Hash + Send + 'static, V: Send + 'static, S: BuildHasher + Default + Send + 'static,

type ReduceA = PushReducer<(K, V), HashMap<K, V, S>>

type ReduceC = ExtendReducer<HashMap<K, V, S>>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<K, V> FromParallelStream<(K, V)> for BTreeMap<K, V>

where K: Ord + Send + 'static, V: Send + 'static,

type ReduceA = PushReducer<(K, V), BTreeMap<K, V>>

type ReduceC = ExtendReducer<BTreeMap<K, V>>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<T, C: FromParallelStream<T>, E> FromParallelStream<Result<T, E>> for Result<C, E>

where E: Send + 'static,

type ReduceA = ResultReducer<<C as FromParallelStream<T>>::ReduceA, E>

type ReduceC = ResultReducer<<C as FromParallelStream<T>>::ReduceC, E>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<T, C: FromParallelStream<T>> FromParallelStream<Option<T>> for Option<C>

type ReduceA = OptionReducer<<C as FromParallelStream<T>>::ReduceA>

type ReduceC = OptionReducer<<C as FromParallelStream<T>>::ReduceC>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<T, S> FromParallelStream<T> for HashSet<T, S>

where T: Eq + Hash + Send + 'static, S: BuildHasher + Default + Send + 'static,

type ReduceA = PushReducer<T, HashSet<T, S>>

type ReduceC = ExtendReducer<HashSet<T, S>>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<T> FromParallelStream<T> for BTreeSet<T>

where T: Ord + Send + 'static,

type ReduceA = PushReducer<T, BTreeSet<T>>

type ReduceC = ExtendReducer<BTreeSet<T>>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<T> FromParallelStream<T> for BinaryHeap<T>

where T: Send + 'static + Ord,

type ReduceA = PushReducer<T, Vec<T>>

type ReduceC = IntoReducer<ExtendReducer<Vec<T>>, BinaryHeap<T>>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<T> FromParallelStream<T> for LinkedList<T>

where T: Send + 'static,

type ReduceA = PushReducer<T, LinkedList<T>>

type ReduceC = ExtendReducer<LinkedList<T>>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<T> FromParallelStream<T> for Vec<T>

where T: Send + 'static,

type ReduceA = PushReducer<T, Vec<T>>

type ReduceC = ExtendReducer<Vec<T>>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

impl<T> FromParallelStream<T> for VecDeque<T>

where T: Send + 'static,

type ReduceA = PushReducer<T, Vec<T>>

type ReduceC = IntoReducer<ExtendReducer<Vec<T>>, VecDeque<T>>

fn reducers() -> (Self::ReduceA, Self::ReduceC)

Implementors