Trait amadeus::par_sink::FromParallelStream[][src]

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

Associated Types

Required methods

fn reducers() -> (Self::ReduceA, Self::ReduceC)[src]

Implementations on Foreign Types

impl FromParallelStream<String> for String[src]

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

impl<T> FromParallelStream<T> for Vec<T, Global> where
    T: Send + 'static, 
[src]

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

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

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

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

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

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

impl<T, C> FromParallelStream<Option<T>> for Option<C> where
    C: FromParallelStream<T>, 
[src]

impl FromParallelStream<char> for String[src]

impl<K, V> FromParallelStream<(K, V)> for BTreeMap<K, V> where
    K: Ord + Send + 'static,
    V: Send + 'static, 
[src]

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

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

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

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, 
[src]

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

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

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

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

impl FromParallelStream<()> for ()[src]

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

Implementors

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