Trait amadeus_core::par_sink::FromParallelStream

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

Associated Types

type ReduceA: ReducerSend<T> + Clone + Send

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

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, Self>

type ReduceC = ExtendReducer<Self>

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>>, Self>

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

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

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

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

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

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

type ReduceA = PushReducer<T, Self>

type ReduceC = ExtendReducer<Self>

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, Self>

type ReduceC = ExtendReducer<Self>

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), Self>

type ReduceC = ExtendReducer<Self>

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

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

type ReduceA = PushReducer<T, Self>

type ReduceC = ExtendReducer<Self>

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), Self>

type ReduceC = ExtendReducer<Self>

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

impl FromParallelStream<char> for String

type ReduceA = PushReducer<char, Self>

type ReduceC = PushReducer<Self>

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

impl FromParallelStream<String> for String

type ReduceA = PushReducer<Self>

type ReduceC = PushReducer<Self>

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

impl FromParallelStream<()> for ()

type ReduceA = PushReducer<Self>

type ReduceC = PushReducer<Self>

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

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

type ReduceA = OptionReducer<C::ReduceA>

type ReduceC = OptionReducer<C::ReduceC>

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::ReduceA, E>

type ReduceC = ResultReducer<C::ReduceC, E>

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

Loading content...

Implementors

Loading content...