[−][src]Trait amadeus_core::par_sink::FromDistributedStream
Associated Types
type ReduceA: ReducerSend<T> + Clone + ProcessSend
type ReduceB: ReducerProcessSend<<Self::ReduceA as ReducerSend<T>>::Output> + Clone + ProcessSend
type ReduceC: Reducer<<Self::ReduceB as ReducerProcessSend<<Self::ReduceA as ReducerSend<T>>::Output>>::Output, Output = Self>
Required methods
Loading content...Implementations on Foreign Types
impl<T> FromDistributedStream<T> for Vec<T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type ReduceA = PushReducer<T, Self>
type ReduceB = ExtendReducer<Self>
type ReduceC = ExtendReducer<Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<T> FromDistributedStream<T> for VecDeque<T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type ReduceA = PushReducer<T, Vec<T>>
type ReduceB = ExtendReducer<Vec<T>>
type ReduceC = IntoReducer<ExtendReducer<Vec<T>>, Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<T: Ord> FromDistributedStream<T> for BinaryHeap<T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type ReduceA = PushReducer<T, Vec<T>>
type ReduceB = ExtendReducer<Vec<T>>
type ReduceC = IntoReducer<ExtendReducer<Vec<T>>, Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<T> FromDistributedStream<T> for LinkedList<T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type ReduceA = PushReducer<T, Self>
type ReduceB = ExtendReducer<Self>
type ReduceC = ExtendReducer<Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<T, S> FromDistributedStream<T> for HashSet<T, S> where
T: Eq + Hash + ProcessSend + 'static,
S: BuildHasher + Default + Send + 'static,
[src]
T: Eq + Hash + ProcessSend + 'static,
S: BuildHasher + Default + Send + 'static,
type ReduceA = PushReducer<T, Self>
type ReduceB = ExtendReducer<Self>
type ReduceC = ExtendReducer<Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
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,
[src]
K: Eq + Hash + ProcessSend + 'static,
V: ProcessSend + 'static,
S: BuildHasher + Default + Send + 'static,
type ReduceA = PushReducer<(K, V), Self>
type ReduceB = ExtendReducer<Self>
type ReduceC = ExtendReducer<Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<T> FromDistributedStream<T> for BTreeSet<T> where
T: Ord + ProcessSend + 'static,
[src]
T: Ord + ProcessSend + 'static,
type ReduceA = PushReducer<T, Self>
type ReduceB = ExtendReducer<Self>
type ReduceC = ExtendReducer<Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<K, V> FromDistributedStream<(K, V)> for BTreeMap<K, V> where
K: Ord + ProcessSend + 'static,
V: ProcessSend + 'static,
[src]
K: Ord + ProcessSend + 'static,
V: ProcessSend + 'static,
type ReduceA = PushReducer<(K, V), Self>
type ReduceB = ExtendReducer<Self>
type ReduceC = ExtendReducer<Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl FromDistributedStream<char> for String
[src]
type ReduceA = PushReducer<char, Self>
type ReduceB = PushReducer<Self>
type ReduceC = PushReducer<Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl FromDistributedStream<String> for String
[src]
type ReduceA = PushReducer<Self>
type ReduceB = PushReducer<Self>
type ReduceC = PushReducer<Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl FromDistributedStream<()> for ()
[src]
type ReduceA = PushReducer<Self>
type ReduceB = PushReducer<Self>
type ReduceC = PushReducer<Self>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<T, C: FromDistributedStream<T>> FromDistributedStream<Option<T>> for Option<C>
[src]
type ReduceA = OptionReducer<C::ReduceA>
type ReduceB = OptionReducer<C::ReduceB>
type ReduceC = OptionReducer<C::ReduceC>
fn reducers() -> (Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<T, C: FromDistributedStream<T>, E> FromDistributedStream<Result<T, E>> for Result<C, E> where
E: ProcessSend + 'static,
[src]
E: ProcessSend + 'static,