[−][src]Trait amadeus_core::dist_iter::FromDistributedIterator

pub trait FromDistributedIterator<T>: Sized {
    type ReduceAFactory: ReduceFactory<Reducer = Self::ReduceA>;
    type ReduceA: ReducerA<Item = T> + ProcessSend;
    type ReduceB: Reducer<Item = <Self::ReduceA as Reducer>::Output, Output = Self>;
    fn reducers() -> (Self::ReduceAFactory, Self::ReduceB);
}

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>`

Loading content...

Required methods

`fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)`

Loading content...

Implementations on Foreign Types

`impl<T> FromDistributedIterator<T> for Vec<T> where T: ProcessSend,` [src]

`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]

`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]

`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]

`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]

`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]

`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]

`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]

`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]

`type ReduceAFactory = ResultReduceFactory<C::ReduceAFactory, E>`

`type ReduceA = ResultReducer<C::ReduceA, E>`

`type ReduceB = ResultReducer<C::ReduceB, E>`

`fn reducers() -> (Self::ReduceAFactory, Self::ReduceB)`[src]

Loading content...

Implementors

Loading content...