[−][src]Trait amadeus_core::dist_iter::FromDistributedIterator
Associated Types
type ReduceAFactory: ReduceFactory<Reducer = Self::ReduceA>
type ReduceA: ReducerA<Item = T> + ProcessSend
type ReduceB: Reducer<Item = <Self::ReduceA as Reducer>::Output, Output = Self>
Required methods
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
Implementations on Foreign Types
impl<T> FromDistributedIterator<T> for Vec<T> where
T: ProcessSend,
[src]
T: ProcessSend,
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<T, Self>
type ReduceB = ExtendReducer<Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl<T> FromDistributedIterator<T> for VecDeque<T> where
T: ProcessSend,
[src]
T: ProcessSend,
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<T, Vec<T>>
type ReduceB = IntoReducer<ExtendReducer<Vec<T>>, Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl<T: Ord> FromDistributedIterator<T> for BinaryHeap<T> where
T: ProcessSend,
[src]
T: ProcessSend,
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<T, Vec<T>>
type ReduceB = IntoReducer<ExtendReducer<Vec<T>>, Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl<T> FromDistributedIterator<T> for LinkedList<T> where
T: ProcessSend,
[src]
T: ProcessSend,
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<T, Self>
type ReduceB = ExtendReducer<Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl<T, S> FromDistributedIterator<T> for HashSet<T, S> where
T: Eq + Hash + ProcessSend,
S: BuildHasher + Default + Send + 'static,
[src]
T: Eq + Hash + ProcessSend,
S: BuildHasher + Default + Send + 'static,
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<T, Self>
type ReduceB = ExtendReducer<Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl<K, V, S> FromDistributedIterator<(K, V)> for HashMap<K, V, S> where
K: Eq + Hash + ProcessSend,
V: ProcessSend,
S: BuildHasher + Default + Send + 'static,
[src]
K: Eq + Hash + ProcessSend,
V: ProcessSend,
S: BuildHasher + Default + Send + 'static,
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<(K, V), Self>
type ReduceB = ExtendReducer<Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl<T> FromDistributedIterator<T> for BTreeSet<T> where
T: Ord + ProcessSend,
[src]
T: Ord + ProcessSend,
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<T, Self>
type ReduceB = ExtendReducer<Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl<K, V> FromDistributedIterator<(K, V)> for BTreeMap<K, V> where
K: Ord + ProcessSend,
V: ProcessSend,
[src]
K: Ord + ProcessSend,
V: ProcessSend,
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<(K, V), Self>
type ReduceB = ExtendReducer<Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl FromDistributedIterator<char> for String
[src]
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<char, Self>
type ReduceB = PushReducer<Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl FromDistributedIterator<String> for String
[src]
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<Self>
type ReduceB = PushReducer<Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl FromDistributedIterator<()> for ()
[src]
type ReduceAFactory = DefaultReduceFactory<Self::ReduceA>
type ReduceA = PushReducer<Self>
type ReduceB = PushReducer<Self>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl<T, C: FromDistributedIterator<T>> FromDistributedIterator<Option<T>> for Option<C>
[src]
type ReduceAFactory = OptionReduceFactory<C::ReduceAFactory>
type ReduceA = OptionReducer<C::ReduceA>
type ReduceB = OptionReducer<C::ReduceB>
fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)
[src]
impl<T, C: FromDistributedIterator<T>, E> FromDistributedIterator<Result<T, E>> for Result<C, E> where
E: ProcessSend,
[src]
E: ProcessSend,