Trait amadeus::FromParallelStream

pub trait FromParallelStream<T> where
    <Self::ReduceC as Reducer<<Self::ReduceA as ReducerSend<T>>::Output>>::Output == Self, {
    type ReduceA: ReducerSend<T> + Clone + Send;
    type ReduceC: Reducer<<Self::ReduceA as ReducerSend<T>>::Output>;
    fn reducers() -> (Self::ReduceA, Self::ReduceC);
}

Associated Types

type ReduceA: ReducerSend<T> + Clone + Send

type ReduceC: Reducer<<Self::ReduceA as ReducerSend<T>>::Output>

Loading content...

Required methods

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

Loading content...

Implementations on Foreign Types

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

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

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

fn reducers(
) -> (<Vec<T> as FromParallelStream<T>>::ReduceA, <Vec<T> as FromParallelStream<T>>::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>, BTreeMap<K, V>>

fn reducers(
) -> (<BTreeMap<K, V> as FromParallelStream<(K, V)>>::ReduceA, <BTreeMap<K, V> as FromParallelStream<(K, V)>>::ReduceC)

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

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

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

fn reducers(
) -> (<HashSet<T, S> as FromParallelStream<T>>::ReduceA, <HashSet<T, S> as FromParallelStream<T>>::ReduceC)

impl FromParallelStream<char> for String

type ReduceA = PushReducer<char, String>

type ReduceC = PushReducer<String, String>

fn reducers(
) -> (<String as FromParallelStream<char>>::ReduceA, <String as FromParallelStream<char>>::ReduceC)

impl FromParallelStream<()> for ()

type ReduceA = PushReducer<(), ()>

type ReduceC = PushReducer<(), ()>

fn reducers(
) -> (<() as FromParallelStream<()>>::ReduceA, <() as FromParallelStream<()>>::ReduceC)

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

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

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

fn reducers(
) -> (<Option<C> as FromParallelStream<Option<T>>>::ReduceA, <Option<C> as FromParallelStream<Option<T>>>::ReduceC)

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

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

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

fn reducers(
) -> (<BinaryHeap<T> as FromParallelStream<T>>::ReduceA, <BinaryHeap<T> as FromParallelStream<T>>::ReduceC)

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

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

type ReduceC = ExtendReducer<BTreeSet<T>, BTreeSet<T>>

fn reducers(
) -> (<BTreeSet<T> as FromParallelStream<T>>::ReduceA, <BTreeSet<T> as FromParallelStream<T>>::ReduceC)

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

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

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

fn reducers(
) -> (<HashMap<K, V, S> as FromParallelStream<(K, V)>>::ReduceA, <HashMap<K, V, S> as FromParallelStream<(K, V)>>::ReduceC)

impl FromParallelStream<String> for String

type ReduceA = PushReducer<String, String>

type ReduceC = PushReducer<String, String>

fn reducers(
) -> (<String as FromParallelStream<String>>::ReduceA, <String as FromParallelStream<String>>::ReduceC)

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

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

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

fn reducers(
) -> (<Result<C, E> as FromParallelStream<Result<T, E>>>::ReduceA, <Result<C, E> as FromParallelStream<Result<T, E>>>::ReduceC)

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

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

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

fn reducers(
) -> (<VecDeque<T> as FromParallelStream<T>>::ReduceA, <VecDeque<T> as FromParallelStream<T>>::ReduceC)

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

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

type ReduceC = ExtendReducer<LinkedList<T>, LinkedList<T>>

fn reducers(
) -> (<LinkedList<T> as FromParallelStream<T>>::ReduceA, <LinkedList<T> as FromParallelStream<T>>::ReduceC)

Loading content...

Implementors

impl<T> FromParallelStream<T> for List<T> where
    T: Data + Send + 'static, 

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

type ReduceC = ExtendReducer<List<T>, List<T>>

fn reducers(
) -> (<List<T> as FromParallelStream<T>>::ReduceA, <List<T> as FromParallelStream<T>>::ReduceC)

Loading content...