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