FromDistributedStream

amadeus_core::par_sink

Trait FromDistributedStream

pub trait FromDistributedStream<T>: Sized {
    type ReduceA: ReducerSend<T> + Clone + ProcessSend;
    type ReduceB: ReducerProcessSend<<Self::ReduceA as ReducerSend<T>>::Done> + Clone + ProcessSend;
    type ReduceC: Reducer<<Self::ReduceB as ReducerProcessSend<<Self::ReduceA as ReducerSend<T>>::Done>>::Done, Done = Self>;

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

Required Associated Types§

type ReduceA: ReducerSend<T> + Clone + ProcessSend

type ReduceB: ReducerProcessSend<<Self::ReduceA as ReducerSend<T>>::Done> + Clone + ProcessSend

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

Required Methods§

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

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§

impl FromDistributedStream<char> for String

type ReduceA = PushReducer<char, String>

type ReduceB = PushReducer<String>

type ReduceC = PushReducer<String>

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

impl FromDistributedStream<()> for ()

type ReduceA = PushReducer<()>

type ReduceB = PushReducer<()>

type ReduceC = PushReducer<()>

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

impl FromDistributedStream<String> for String

type ReduceA = PushReducer<String>

type ReduceB = PushReducer<String>

type ReduceC = PushReducer<String>

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

impl<K, V> FromDistributedStream<(K, V)> for BTreeMap<K, V>
where K: Ord + ProcessSend + 'static, V: ProcessSend + 'static,

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

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

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

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

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

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

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

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

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

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

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

type ReduceB = ExtendReducer<Vec<T>>

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

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

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

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

type ReduceB = ExtendReducer<BTreeSet<T>>

type ReduceC = ExtendReducer<BTreeSet<T>>

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

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

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

type ReduceB = ExtendReducer<LinkedList<T>>

type ReduceC = ExtendReducer<LinkedList<T>>

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

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

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

type ReduceB = ExtendReducer<Vec<T>>

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

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

impl<T> FromDistributedStream<T> for Vec<T>
where T: ProcessSend + 'static,

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

type ReduceB = ExtendReducer<Vec<T>>

type ReduceC = ExtendReducer<Vec<T>>

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

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

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

type ReduceB = OptionReducer<<C as FromDistributedStream<T>>::ReduceB>

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

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

impl<T, C: FromDistributedStream<T>, E> FromDistributedStream<Result<T, E>> for Result<C, E>
where E: ProcessSend + 'static,

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

type ReduceB = ResultReducer<<C as FromDistributedStream<T>>::ReduceB, E>

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

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

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

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

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

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

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

Implementors§