Trait amadeus::FromDistributedIterator

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

Associated Types

type ReduceAFactory: ReduceFactory

type ReduceA: ReducerA + ProcessSend

type ReduceB: Reducer

Loading content...

Required methods

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

Loading content...

Implementations on Foreign Types

impl<T> FromDistributedIterator<T> for BTreeSet<T> where
    T: Ord + ProcessSend, 

type ReduceAFactory = DefaultReduceFactory<<BTreeSet<T> as FromDistributedIterator<T>>::ReduceA>

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

type ReduceB = ExtendReducer<BTreeSet<T>, BTreeSet<T>>

fn reducers(
) -> (<BTreeSet<T> as FromDistributedIterator<T>>::ReduceAFactory, <BTreeSet<T> as FromDistributedIterator<T>>::ReduceB)

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

type ReduceAFactory = DefaultReduceFactory<<HashSet<T, S> as FromDistributedIterator<T>>::ReduceA>

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

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

fn reducers(
) -> (<HashSet<T, S> as FromDistributedIterator<T>>::ReduceAFactory, <HashSet<T, S> as FromDistributedIterator<T>>::ReduceB)

impl<T> FromDistributedIterator<T> for VecDeque<T> where
    T: ProcessSend, 

type ReduceAFactory = DefaultReduceFactory<<VecDeque<T> as FromDistributedIterator<T>>::ReduceA>

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

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

fn reducers(
) -> (<VecDeque<T> as FromDistributedIterator<T>>::ReduceAFactory, <VecDeque<T> as FromDistributedIterator<T>>::ReduceB)

impl<T> FromDistributedIterator<T> for BinaryHeap<T> where
    T: Ord + ProcessSend, 

type ReduceAFactory = DefaultReduceFactory<<BinaryHeap<T> as FromDistributedIterator<T>>::ReduceA>

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

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

fn reducers(
) -> (<BinaryHeap<T> as FromDistributedIterator<T>>::ReduceAFactory, <BinaryHeap<T> as FromDistributedIterator<T>>::ReduceB)

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

type ReduceAFactory = DefaultReduceFactory<<HashMap<K, V, S> as FromDistributedIterator<(K, V)>>::ReduceA>

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

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

fn reducers(
) -> (<HashMap<K, V, S> as FromDistributedIterator<(K, V)>>::ReduceAFactory, <HashMap<K, V, S> as FromDistributedIterator<(K, V)>>::ReduceB)

impl<T, C> FromDistributedIterator<Option<T>> for Option<C> where
    C: FromDistributedIterator<T>, 

type ReduceAFactory = OptionReduceFactory<<C as FromDistributedIterator<T>>::ReduceAFactory>

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

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

fn reducers(
) -> (<Option<C> as FromDistributedIterator<Option<T>>>::ReduceAFactory, <Option<C> as FromDistributedIterator<Option<T>>>::ReduceB)

impl<K, V> FromDistributedIterator<(K, V)> for BTreeMap<K, V> where
    K: Ord + ProcessSend,
    V: ProcessSend, 

type ReduceAFactory = DefaultReduceFactory<<BTreeMap<K, V> as FromDistributedIterator<(K, V)>>::ReduceA>

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

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

fn reducers(
) -> (<BTreeMap<K, V> as FromDistributedIterator<(K, V)>>::ReduceAFactory, <BTreeMap<K, V> as FromDistributedIterator<(K, V)>>::ReduceB)

impl<T> FromDistributedIterator<T> for Vec<T> where
    T: ProcessSend, 

type ReduceAFactory = DefaultReduceFactory<<Vec<T> as FromDistributedIterator<T>>::ReduceA>

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

type ReduceB = ExtendReducer<Vec<T>, Vec<T>>

fn reducers(
) -> (<Vec<T> as FromDistributedIterator<T>>::ReduceAFactory, <Vec<T> as FromDistributedIterator<T>>::ReduceB)

impl<T, C, E> FromDistributedIterator<Result<T, E>> for Result<C, E> where
    C: FromDistributedIterator<T>,
    E: ProcessSend, 

type ReduceAFactory = ResultReduceFactory<<C as FromDistributedIterator<T>>::ReduceAFactory, E>

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

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

fn reducers(
) -> (<Result<C, E> as FromDistributedIterator<Result<T, E>>>::ReduceAFactory, <Result<C, E> as FromDistributedIterator<Result<T, E>>>::ReduceB)

impl FromDistributedIterator<char> for String

type ReduceAFactory = DefaultReduceFactory<<String as FromDistributedIterator<char>>::ReduceA>

type ReduceA = PushReducer<char, String>

type ReduceB = PushReducer<String, String>

fn reducers(
) -> (<String as FromDistributedIterator<char>>::ReduceAFactory, <String as FromDistributedIterator<char>>::ReduceB)

impl<T> FromDistributedIterator<T> for LinkedList<T> where
    T: ProcessSend, 

type ReduceAFactory = DefaultReduceFactory<<LinkedList<T> as FromDistributedIterator<T>>::ReduceA>

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

type ReduceB = ExtendReducer<LinkedList<T>, LinkedList<T>>

fn reducers(
) -> (<LinkedList<T> as FromDistributedIterator<T>>::ReduceAFactory, <LinkedList<T> as FromDistributedIterator<T>>::ReduceB)

impl FromDistributedIterator<String> for String

type ReduceAFactory = DefaultReduceFactory<<String as FromDistributedIterator<String>>::ReduceA>

type ReduceA = PushReducer<String, String>

type ReduceB = PushReducer<String, String>

fn reducers(
) -> (<String as FromDistributedIterator<String>>::ReduceAFactory, <String as FromDistributedIterator<String>>::ReduceB)

impl FromDistributedIterator<()> for ()

type ReduceAFactory = DefaultReduceFactory<<() as FromDistributedIterator<()>>::ReduceA>

type ReduceA = PushReducer<(), ()>

type ReduceB = PushReducer<(), ()>

fn reducers(
) -> (<() as FromDistributedIterator<()>>::ReduceAFactory, <() as FromDistributedIterator<()>>::ReduceB)

Loading content...

Implementors

Loading content...