[][src]Trait amadeus::FromDistributedStream

pub trait FromDistributedStream<T> where
    <Self::ReduceAFactory as Factory>::Item == Self::ReduceA,
    <Self::ReduceBFactory as Factory>::Item == Self::ReduceB,
    <Self::ReduceA as Reducer>::Item == T,
    <Self::ReduceB as Reducer>::Item == <Self::ReduceA as Reducer>::Output,
    <Self::ReduceC as Reducer>::Item == <Self::ReduceB as Reducer>::Output,
    <Self::ReduceC as Reducer>::Output == Self, 
{ type ReduceAFactory: Factory + ProcessSend + Clone; type ReduceBFactory: Factory; type ReduceA: ReducerSend + Send; type ReduceB: ReducerProcessSend + ProcessSend; type ReduceC: Reducer; fn reducers() -> (Self::ReduceAFactory, Self::ReduceBFactory, Self::ReduceC); }

Associated Types

Loading content...

Required methods

fn reducers() -> (Self::ReduceAFactory, Self::ReduceBFactory, Self::ReduceC)

Loading content...

Implementations on Foreign Types

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

impl FromDistributedStream<String> for String[src]

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

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

impl FromDistributedStream<()> for ()[src]

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

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

impl<T, C> FromDistributedStream<Option<T>> for Option<C> where
    C: FromDistributedStream<T>, 
[src]

impl FromDistributedStream<char> for String[src]

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

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

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

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

Loading content...

Implementors

Loading content...