[−][src]Trait amadeus::IntoDistributedStream
Associated Types
type DistStream: DistributedStream
type Item
Required methods
fn into_dist_stream(self) -> Self::DistStream
Provided methods
fn par_stream_mut(&mut self) -> <&mut Self as IntoDistributedStream>::DistStream where
&'a mut Self: for<'a> IntoDistributedStream,
&'a mut Self: for<'a> IntoDistributedStream,
fn dist_stream(&self) -> <&Self as IntoDistributedStream>::DistStream where
&'a Self: for<'a> IntoDistributedStream,
&'a Self: for<'a> IntoDistributedStream,
Implementations on Foreign Types
impl<Idx> IntoDistributedStream for RangeInclusive<Idx> where
RangeInclusive<Idx>: Iterator,
<RangeInclusive<Idx> as Iterator>::Item: ProcessSend,
<RangeInclusive<Idx> as Iterator>::Item: 'static,
[src]
RangeInclusive<Idx>: Iterator,
<RangeInclusive<Idx> as Iterator>::Item: ProcessSend,
<RangeInclusive<Idx> as Iterator>::Item: 'static,
type DistStream = IterDistStream<RangeInclusive<Idx>>
type Item = <RangeInclusive<Idx> as Iterator>::Item
fn into_dist_stream(
self
) -> <RangeInclusive<Idx> as IntoDistributedStream>::DistStream where
RangeInclusive<Idx>: Sized,
[src]
self
) -> <RangeInclusive<Idx> as IntoDistributedStream>::DistStream where
RangeInclusive<Idx>: Sized,
impl<'a, T> IntoDistributedStream for &'a VecDeque<T> where
T: Clone + ProcessSend + 'static,
[src]
T: Clone + ProcessSend + 'static,
type DistStream = IterDistStream<Cloned<Iter<'a, T>>>
type Item = T
fn into_dist_stream(
self
) -> <&'a VecDeque<T> as IntoDistributedStream>::DistStream where
&'a VecDeque<T>: Sized,
[src]
self
) -> <&'a VecDeque<T> as IntoDistributedStream>::DistStream where
&'a VecDeque<T>: Sized,
impl<'a, K, V> IntoDistributedStream for &'a BTreeMap<K, V> where
K: Clone + ProcessSend + 'static,
V: Clone + ProcessSend + 'static,
[src]
K: Clone + ProcessSend + 'static,
V: Clone + ProcessSend + 'static,
type DistStream = IterDistStream<TupleCloned<Iter<'a, K, V>>>
type Item = (K, V)
fn into_dist_stream(
self
) -> <&'a BTreeMap<K, V> as IntoDistributedStream>::DistStream where
&'a BTreeMap<K, V>: Sized,
[src]
self
) -> <&'a BTreeMap<K, V> as IntoDistributedStream>::DistStream where
&'a BTreeMap<K, V>: Sized,
impl<T> IntoDistributedStream for BTreeSet<T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<T>>
type Item = T
fn into_dist_stream(self) -> <BTreeSet<T> as IntoDistributedStream>::DistStream where
BTreeSet<T>: Sized,
[src]
BTreeSet<T>: Sized,
impl<'a, T> IntoDistributedStream for &'a LinkedList<T> where
T: Clone + ProcessSend + 'static,
[src]
T: Clone + ProcessSend + 'static,
type DistStream = IterDistStream<Cloned<Iter<'a, T>>>
type Item = T
fn into_dist_stream(
self
) -> <&'a LinkedList<T> as IntoDistributedStream>::DistStream where
&'a LinkedList<T>: Sized,
[src]
self
) -> <&'a LinkedList<T> as IntoDistributedStream>::DistStream where
&'a LinkedList<T>: Sized,
impl<'a, K, V, S> IntoDistributedStream for &'a HashMap<K, V, S> where
K: Clone + Eq + Hash + ProcessSend + 'static,
S: BuildHasher + Default,
V: Clone + ProcessSend + 'static,
[src]
K: Clone + Eq + Hash + ProcessSend + 'static,
S: BuildHasher + Default,
V: Clone + ProcessSend + 'static,
type DistStream = IterDistStream<TupleCloned<Iter<'a, K, V>>>
type Item = (K, V)
fn into_dist_stream(
self
) -> <&'a HashMap<K, V, S> as IntoDistributedStream>::DistStream where
&'a HashMap<K, V, S>: Sized,
[src]
self
) -> <&'a HashMap<K, V, S> as IntoDistributedStream>::DistStream where
&'a HashMap<K, V, S>: Sized,
impl<'a, T> IntoDistributedStream for &'a BinaryHeap<T> where
T: Clone + Ord + ProcessSend + 'static,
[src]
T: Clone + Ord + ProcessSend + 'static,
type DistStream = IterDistStream<Cloned<Iter<'a, T>>>
type Item = T
fn into_dist_stream(
self
) -> <&'a BinaryHeap<T> as IntoDistributedStream>::DistStream where
&'a BinaryHeap<T>: Sized,
[src]
self
) -> <&'a BinaryHeap<T> as IntoDistributedStream>::DistStream where
&'a BinaryHeap<T>: Sized,
impl<T> IntoDistributedStream for BinaryHeap<T> where
T: Ord + ProcessSend + 'static,
[src]
T: Ord + ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<T>>
type Item = T
fn into_dist_stream(
self
) -> <BinaryHeap<T> as IntoDistributedStream>::DistStream where
BinaryHeap<T>: Sized,
[src]
self
) -> <BinaryHeap<T> as IntoDistributedStream>::DistStream where
BinaryHeap<T>: Sized,
impl<T> IntoDistributedStream for Vec<T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<T>>
type Item = T
fn into_dist_stream(self) -> <Vec<T> as IntoDistributedStream>::DistStream where
Vec<T>: Sized,
[src]
Vec<T>: Sized,
impl<T> IntoDistributedStream for VecDeque<T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<T>>
type Item = T
fn into_dist_stream(self) -> <VecDeque<T> as IntoDistributedStream>::DistStream where
VecDeque<T>: Sized,
[src]
VecDeque<T>: Sized,
impl<T, S> IntoDistributedStream for HashSet<T, S> where
S: BuildHasher + Default,
T: Eq + Hash + ProcessSend + 'static,
[src]
S: BuildHasher + Default,
T: Eq + Hash + ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<T>>
type Item = T
fn into_dist_stream(
self
) -> <HashSet<T, S> as IntoDistributedStream>::DistStream where
HashSet<T, S>: Sized,
[src]
self
) -> <HashSet<T, S> as IntoDistributedStream>::DistStream where
HashSet<T, S>: Sized,
impl<K, V, S> IntoDistributedStream for HashMap<K, V, S> where
K: Eq + Hash + ProcessSend + 'static,
S: BuildHasher + Default,
V: ProcessSend + 'static,
[src]
K: Eq + Hash + ProcessSend + 'static,
S: BuildHasher + Default,
V: ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<K, V>>
type Item = (K, V)
fn into_dist_stream(
self
) -> <HashMap<K, V, S> as IntoDistributedStream>::DistStream where
HashMap<K, V, S>: Sized,
[src]
self
) -> <HashMap<K, V, S> as IntoDistributedStream>::DistStream where
HashMap<K, V, S>: Sized,
impl<'a, T, E> IntoDistributedStream for &'a Result<T, E> where
T: Clone + ProcessSend + 'static,
[src]
T: Clone + ProcessSend + 'static,
type DistStream = IterDistStream<Cloned<Iter<'a, T>>>
type Item = T
fn into_dist_stream(
self
) -> <&'a Result<T, E> as IntoDistributedStream>::DistStream where
&'a Result<T, E>: Sized,
[src]
self
) -> <&'a Result<T, E> as IntoDistributedStream>::DistStream where
&'a Result<T, E>: Sized,
impl<T, E> IntoDistributedStream for Result<T, E> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<T>>
type Item = T
fn into_dist_stream(self) -> <Result<T, E> as IntoDistributedStream>::DistStream where
Result<T, E>: Sized,
[src]
Result<T, E>: Sized,
impl<'a, T> IntoDistributedStream for &'a Option<T> where
T: Clone + ProcessSend + 'static,
[src]
T: Clone + ProcessSend + 'static,
type DistStream = IterDistStream<Cloned<Iter<'a, T>>>
type Item = T
fn into_dist_stream(
self
) -> <&'a Option<T> as IntoDistributedStream>::DistStream where
&'a Option<T>: Sized,
[src]
self
) -> <&'a Option<T> as IntoDistributedStream>::DistStream where
&'a Option<T>: Sized,
impl<'a, T> IntoDistributedStream for &'a [T] where
T: Clone + ProcessSend + 'static,
[src]
T: Clone + ProcessSend + 'static,
type DistStream = IterDistStream<Cloned<Iter<'a, T>>>
type Item = T
fn into_dist_stream(self) -> <&'a [T] as IntoDistributedStream>::DistStreamⓘ where
&'a [T]: Sized,
[src]
&'a [T]: Sized,
impl<'a, T, S> IntoDistributedStream for &'a HashSet<T, S> where
S: BuildHasher + Default,
T: Clone + Eq + Hash + ProcessSend + 'static,
[src]
S: BuildHasher + Default,
T: Clone + Eq + Hash + ProcessSend + 'static,
type DistStream = IterDistStream<Cloned<Iter<'a, T>>>
type Item = T
fn into_dist_stream(
self
) -> <&'a HashSet<T, S> as IntoDistributedStream>::DistStream where
&'a HashSet<T, S>: Sized,
[src]
self
) -> <&'a HashSet<T, S> as IntoDistributedStream>::DistStream where
&'a HashSet<T, S>: Sized,
impl<T> IntoDistributedStream for LinkedList<T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<T>>
type Item = T
fn into_dist_stream(
self
) -> <LinkedList<T> as IntoDistributedStream>::DistStream where
LinkedList<T>: Sized,
[src]
self
) -> <LinkedList<T> as IntoDistributedStream>::DistStream where
LinkedList<T>: Sized,
impl<'a, T> IntoDistributedStream for &'a Vec<T> where
T: Clone + ProcessSend + 'static,
[src]
T: Clone + ProcessSend + 'static,
type DistStream = IterDistStream<Cloned<Iter<'a, T>>>
type Item = T
fn into_dist_stream(self) -> <&'a Vec<T> as IntoDistributedStream>::DistStream where
&'a Vec<T>: Sized,
[src]
&'a Vec<T>: Sized,
impl<T> IntoDistributedStream for [T] where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type DistStream = Never
type Item = Never
fn into_dist_stream(self) -> <[T] as IntoDistributedStream>::DistStreamⓘ where
[T]: Sized,
[src]
[T]: Sized,
impl<Idx> IntoDistributedStream for RangeFrom<Idx> where
RangeFrom<Idx>: Iterator,
<RangeFrom<Idx> as Iterator>::Item: ProcessSend,
<RangeFrom<Idx> as Iterator>::Item: 'static,
[src]
RangeFrom<Idx>: Iterator,
<RangeFrom<Idx> as Iterator>::Item: ProcessSend,
<RangeFrom<Idx> as Iterator>::Item: 'static,
type DistStream = IterDistStream<RangeFrom<Idx>>
type Item = <RangeFrom<Idx> as Iterator>::Item
fn into_dist_stream(
self
) -> <RangeFrom<Idx> as IntoDistributedStream>::DistStream where
RangeFrom<Idx>: Sized,
[src]
self
) -> <RangeFrom<Idx> as IntoDistributedStream>::DistStream where
RangeFrom<Idx>: Sized,
impl<T> IntoDistributedStream for Option<T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<T>>
type Item = T
fn into_dist_stream(self) -> <Option<T> as IntoDistributedStream>::DistStream where
Option<T>: Sized,
[src]
Option<T>: Sized,
impl<'a> IntoDistributedStream for &'a String
[src]
type DistStream = IterDistStream<Chars<'a>>
type Item = char
fn into_dist_stream(self) -> <&'a String as IntoDistributedStream>::DistStream where
&'a String: Sized,
[src]
&'a String: Sized,
impl<K, V> IntoDistributedStream for BTreeMap<K, V> where
K: ProcessSend + 'static,
V: ProcessSend + 'static,
[src]
K: ProcessSend + 'static,
V: ProcessSend + 'static,
type DistStream = IterDistStream<IntoIter<K, V>>
type Item = (K, V)
fn into_dist_stream(
self
) -> <BTreeMap<K, V> as IntoDistributedStream>::DistStream where
BTreeMap<K, V>: Sized,
[src]
self
) -> <BTreeMap<K, V> as IntoDistributedStream>::DistStream where
BTreeMap<K, V>: Sized,
impl IntoDistributedStream for String
[src]
type DistStream = IterDistStream<OwnedChars>
type Item = char
fn into_dist_stream(self) -> <String as IntoDistributedStream>::DistStream where
String: Sized,
[src]
String: Sized,
impl<'a, T> IntoDistributedStream for &'a BTreeSet<T> where
T: Clone + ProcessSend + 'static,
[src]
T: Clone + ProcessSend + 'static,
type DistStream = IterDistStream<Cloned<Iter<'a, T>>>
type Item = T
fn into_dist_stream(
self
) -> <&'a BTreeSet<T> as IntoDistributedStream>::DistStream where
&'a BTreeSet<T>: Sized,
[src]
self
) -> <&'a BTreeSet<T> as IntoDistributedStream>::DistStream where
&'a BTreeSet<T>: Sized,
impl<Idx> IntoDistributedStream for Range<Idx> where
Range<Idx>: Iterator,
<Range<Idx> as Iterator>::Item: ProcessSend,
<Range<Idx> as Iterator>::Item: 'static,
[src]
Range<Idx>: Iterator,
<Range<Idx> as Iterator>::Item: ProcessSend,
<Range<Idx> as Iterator>::Item: 'static,
type DistStream = IterDistStream<Range<Idx>>
type Item = <Range<Idx> as Iterator>::Item
fn into_dist_stream(self) -> <Range<Idx> as IntoDistributedStream>::DistStream where
Range<Idx>: Sized,
[src]
Range<Idx>: Sized,
Implementors
impl<T> IntoDistributedStream for T where
T: DistributedStream,
[src]
T: DistributedStream,