Skip to main content

Cloned

amadeus_core::par_stream

Struct Cloned 

Source 
pub struct Cloned<P, T, Input> { /* private fields */ }

Implementations§

Source§

impl<P, T, Input> Cloned<P, T, Input>

Source

pub fn new(pipe: P) -> Self

Constructs a new Cloned.

Trait Implementations§

Source§

impl<'a, P, Input, T> DistributedPipe<&'a Input> for Cloned<P, T, Input>
where P: ParallelPipe<&'a Input, Output = &'a T>, T: Clone + 'a,

Source§

type Output = T

Source§

type Task = ClonedTask<<P as DistributedPipe<&'a Input>>::Task>

Source§

fn task(&self) -> Self::Task

Source§

fn inspect<F>(self, f: F) -> Inspect<Self, F>
where F: FnMut(&Self::Output) + Clone + ProcessSend + 'static, Self: Sized,

Source§

fn update<F>(self, f: F) -> Update<Self, F>
where F: FnMut(&mut Self::Output) + Clone + ProcessSend + 'static, Self: Sized,

Source§

fn map<B, F>(self, f: F) -> Map<Self, F>
where F: FnMut(Self::Output) -> B + Clone + ProcessSend + 'static, Self: Sized,

Source§

fn flat_map<B, F>(self, f: F) -> FlatMap<Self, F>
where F: FnMut(Self::Output) -> B + Clone + ProcessSend + 'static, B: Stream, Self: Sized,

Source§

fn filter<F>(self, f: F) -> Filter<Self, F>
where F: FnMut(&Self::Output) -> bool + Clone + ProcessSend + 'static, Self: Sized,

Source§

fn cloned<'a, T>(self) -> Cloned<Self, T, Input>
where T: Clone + 'a, Input: 'a, Self: DistributedPipe<&'a Input, Output = &'a T> + Sized,

Source§

fn left_join<K, V1, V2>( self, right: impl IntoIterator<Item = (K, V2)>, ) -> LeftJoin<Self, K, V1, V2>
where K: Eq + Hash + Clone + ProcessSend + 'static, V1: 'static, V2: Clone + ProcessSend + 'static, Self: DistributedPipe<Input, Output = (K, V1)> + Sized,

Source§

fn inner_join<K, V1, V2>( self, right: impl IntoIterator<Item = (K, V2)>, ) -> InnerJoin<Self, K, V1, V2>
where K: Eq + Hash + Clone + ProcessSend + 'static, V1: 'static, V2: Clone + ProcessSend + 'static, Self: DistributedPipe<Input, Output = (K, V1)> + Sized,

Source§

fn pipe<S>(self, sink: S) -> Pipe<Self, S>
where S: DistributedSink<Self::Output>, Self: Sized,

Source§

fn fork<A, B, RefAItem>( self, sink: A, sink_ref: B, ) -> Fork<Self, A, B, &'static Self::Output>
where A: DistributedSink<Self::Output>, B: for<'a> DistributedSink<&'a Self::Output>, Self: Sized,

Source§

fn for_each<F>(self, f: F) -> ForEach<Self, F>
where F: FnMut(Self::Output) + Clone + ProcessSend + 'static, Self: Sized,

Source§

fn fold<ID, F, B>(self, identity: ID, op: F) -> Fold<Self, ID, F, B>
where ID: FnMut() -> B + Clone + ProcessSend + 'static, F: FnMut(B, Either<Self::Output, B>) -> B + Clone + ProcessSend + 'static, B: ProcessSend + 'static, Self: Sized,

Source§

fn group_by<S, A, B>(self, sink: S) -> GroupBy<Self, S>
where A: Eq + Hash + ProcessSend + 'static, S: DistributedSink<B>, <S::Pipe as DistributedPipe<B>>::Task: Clone + ProcessSend + 'static, S::ReduceA: 'static, S::ReduceC: Clone, S::Done: ProcessSend + 'static, Self: DistributedPipe<Input, Output = (A, B)> + Sized,

Source§

fn histogram(self) -> Histogram<Self>
where Self::Output: Hash + Ord + ProcessSend + 'static, Self: Sized,

Source§

fn sort_n_by<F>(self, n: usize, cmp: F) -> Sort<Self, F>
where F: Fn(&Self::Output, &Self::Output) -> Ordering + Clone + ProcessSend + 'static, Self::Output: Clone + ProcessSend + 'static, Self: Sized,

Source§

fn count(self) -> Count<Self>
where Self: Sized,

Source§

fn sum<B>(self) -> Sum<Self, B>
where B: Sum<Self::Output> + Sum<B> + ProcessSend + 'static, Self: Sized,

Source§

fn mean(self) -> Mean<Self>
where Self: DistributedPipe<Input, Output = f64> + Sized,

Source§

fn stddev(self) -> StdDev<Self>
where Self: DistributedPipe<Input, Output = f64> + Sized,

Source§

fn combine<F>(self, f: F) -> Combine<Self, F>
where F: FnMut(Self::Output, Self::Output) -> Self::Output + Clone + ProcessSend + 'static, Self::Output: ProcessSend + 'static, Self: Sized,

Source§

fn max(self) -> Max<Self>
where Self::Output: Ord + ProcessSend + 'static, Self: Sized,

Source§

fn max_by<F>(self, f: F) -> MaxBy<Self, F>
where F: FnMut(&Self::Output, &Self::Output) -> Ordering + Clone + ProcessSend + 'static, Self::Output: ProcessSend + 'static, Self: Sized,

Source§

fn max_by_key<F, B>(self, f: F) -> MaxByKey<Self, F>
where F: FnMut(&Self::Output) -> B + Clone + ProcessSend + 'static, B: Ord + 'static, Self::Output: ProcessSend + 'static, Self: Sized,

Source§

fn min(self) -> Min<Self>
where Self::Output: Ord + ProcessSend + 'static, Self: Sized,

Source§

fn min_by<F>(self, f: F) -> MinBy<Self, F>
where F: FnMut(&Self::Output, &Self::Output) -> Ordering + Clone + ProcessSend + 'static, Self::Output: ProcessSend + 'static, Self: Sized,

Source§

fn min_by_key<F, B>(self, f: F) -> MinByKey<Self, F>
where F: FnMut(&Self::Output) -> B + Clone + ProcessSend + 'static, B: Ord + 'static, Self::Output: ProcessSend + 'static, Self: Sized,

Source§

fn most_frequent( self, n: usize, probability: f64, tolerance: f64, ) -> MostFrequent<Self>
where Self::Output: Hash + Eq + Clone + ProcessSend + 'static, Self: Sized,

Source§

fn most_distinct<A, B>( self, n: usize, probability: f64, tolerance: f64, error_rate: f64, ) -> MostDistinct<Self>
where Self: DistributedPipe<Input, Output = (A, B)> + Sized, A: Hash + Eq + Clone + ProcessSend + 'static, B: Hash + 'static,

Source§

fn sample_unstable(self, samples: usize) -> SampleUnstable<Self>
where Self::Output: ProcessSend + 'static, Self: Sized,

Source§

fn all<F>(self, f: F) -> All<Self, F>
where F: FnMut(Self::Output) -> bool + Clone + ProcessSend + 'static, Self: Sized,

Source§

fn any<F>(self, f: F) -> Any<Self, F>
where F: FnMut(Self::Output) -> bool + Clone + ProcessSend + 'static, Self: Sized,

Source§

fn collect<B>(self) -> Collect<Self, B>
where B: FromDistributedStream<Self::Output>, Self: Sized,

Source§

impl<'a, P, Input, T> ParallelPipe<&'a Input> for Cloned<P, T, Input>
where P: ParallelPipe<&'a Input, Output = &'a T>, T: Clone + 'a,

Source§

type Output = T

Source§

type Task = ClonedTask<<P as ParallelPipe<&'a Input>>::Task>

Source§

fn task(&self) -> Self::Task

Source§

fn inspect<F>(self, f: F) -> Inspect<Self, F>
where F: FnMut(&Self::Output) + Clone + Send + 'static, Self: Sized,

Source§

fn update<F>(self, f: F) -> Update<Self, F>
where F: FnMut(&mut Self::Output) + Clone + Send + 'static, Self: Sized,

Source§

fn map<B, F>(self, f: F) -> Map<Self, F>
where F: FnMut(Self::Output) -> B + Clone + Send + 'static, Self: Sized,

Source§

fn flat_map<B, F>(self, f: F) -> FlatMap<Self, F>
where F: FnMut(Self::Output) -> B + Clone + Send + 'static, B: Stream, Self: Sized,

Source§

fn filter<F>(self, f: F) -> Filter<Self, F>
where F: FnMut(&Self::Output) -> bool + Clone + Send + 'static, Self: Sized,

Source§

fn cloned<'a, T>(self) -> Cloned<Self, T, Input>
where T: Clone + 'a, Input: 'a, Self: ParallelPipe<&'a Input, Output = &'a T> + Sized,

Source§

fn left_join<K, V1, V2>( self, right: impl IntoIterator<Item = (K, V2)>, ) -> LeftJoin<Self, K, V1, V2>
where K: Eq + Hash + Clone + Send + 'static, V1: 'static, V2: Clone + Send + 'static, Self: ParallelPipe<Input, Output = (K, V1)> + Sized,

Source§

fn inner_join<K, V1, V2>( self, right: impl IntoIterator<Item = (K, V2)>, ) -> InnerJoin<Self, K, V1, V2>
where K: Eq + Hash + Clone + Send + 'static, V1: 'static, V2: Clone + Send + 'static, Self: ParallelPipe<Input, Output = (K, V1)> + Sized,

Source§

fn pipe<S>(self, sink: S) -> Pipe<Self, S>
where S: ParallelSink<Self::Output>, Self: Sized,

Source§

fn fork<A, B, RefAItem>( self, sink: A, sink_ref: B, ) -> Fork<Self, A, B, &'static Self::Output>
where A: ParallelSink<Self::Output>, B: for<'a> ParallelSink<&'a Self::Output>, Self: Sized,

Source§

fn for_each<F>(self, f: F) -> ForEach<Self, F>
where F: FnMut(Self::Output) + Clone + Send + 'static, Self: Sized,

Source§

fn fold<ID, F, B>(self, identity: ID, op: F) -> Fold<Self, ID, F, B>
where ID: FnMut() -> B + Clone + Send + 'static, F: FnMut(B, Either<Self::Output, B>) -> B + Clone + Send + 'static, B: Send + 'static, Self: Sized,

Source§

fn group_by<S, A, B>(self, sink: S) -> GroupBy<Self, S>
where A: Eq + Hash + Send + 'static, S: ParallelSink<B>, <S::Pipe as ParallelPipe<B>>::Task: Clone + Send + 'static, S::ReduceA: 'static, S::ReduceC: Clone, S::Done: Send + 'static, Self: ParallelPipe<Input, Output = (A, B)> + Sized,

Source§

fn histogram(self) -> Histogram<Self>
where Self::Output: Hash + Ord + Send + 'static, Self: Sized,

Source§

fn sort_n_by<F>(self, n: usize, cmp: F) -> Sort<Self, F>
where F: Fn(&Self::Output, &Self::Output) -> Ordering + Clone + Send + 'static, Self::Output: Clone + Send + 'static, Self: Sized,

Source§

fn count(self) -> Count<Self>
where Self: Sized,

Source§

fn sum<B>(self) -> Sum<Self, B>
where B: Sum<Self::Output> + Sum<B> + Send + 'static, Self: Sized,

Source§

fn mean(self) -> Mean<Self>
where Self: ParallelPipe<Input, Output = f64> + Sized,

Source§

fn stddev(self) -> StdDev<Self>
where Self: ParallelPipe<Input, Output = f64> + Sized,

Source§

fn combine<F>(self, f: F) -> Combine<Self, F>
where F: FnMut(Self::Output, Self::Output) -> Self::Output + Clone + Send + 'static, Self::Output: Send + 'static, Self: Sized,

Source§

fn max(self) -> Max<Self>
where Self::Output: Ord + Send + 'static, Self: Sized,

Source§

fn max_by<F>(self, f: F) -> MaxBy<Self, F>
where F: FnMut(&Self::Output, &Self::Output) -> Ordering + Clone + Send + 'static, Self::Output: Send + 'static, Self: Sized,

Source§

fn max_by_key<F, B>(self, f: F) -> MaxByKey<Self, F>
where F: FnMut(&Self::Output) -> B + Clone + Send + 'static, B: Ord + 'static, Self::Output: Send + 'static, Self: Sized,

Source§

fn min(self) -> Min<Self>
where Self::Output: Ord + Send + 'static, Self: Sized,

Source§

fn min_by<F>(self, f: F) -> MinBy<Self, F>
where F: FnMut(&Self::Output, &Self::Output) -> Ordering + Clone + Send + 'static, Self::Output: Send + 'static, Self: Sized,

Source§

fn min_by_key<F, B>(self, f: F) -> MinByKey<Self, F>
where F: FnMut(&Self::Output) -> B + Clone + Send + 'static, B: Ord + 'static, Self::Output: Send + 'static, Self: Sized,

Source§

fn most_frequent( self, n: usize, probability: f64, tolerance: f64, ) -> MostFrequent<Self>
where Self::Output: Hash + Eq + Clone + Send + 'static, Self: Sized,

Source§

fn most_distinct<A, B>( self, n: usize, probability: f64, tolerance: f64, error_rate: f64, ) -> MostDistinct<Self>
where Self: ParallelPipe<Input, Output = (A, B)> + Sized, A: Hash + Eq + Clone + Send + 'static, B: Hash + 'static,

Source§

fn sample_unstable(self, samples: usize) -> SampleUnstable<Self>
where Self::Output: Send + 'static, Self: Sized,

Source§

fn all<F>(self, f: F) -> All<Self, F>
where F: FnMut(Self::Output) -> bool + Clone + Send + 'static, Self: Sized,

Source§

fn any<F>(self, f: F) -> Any<Self, F>
where F: FnMut(Self::Output) -> bool + Clone + Send + 'static, Self: Sized,

Source§

fn collect<B>(self) -> Collect<Self, B>
where B: FromParallelStream<Self::Output>, Self: Sized,

Auto Trait Implementations§

§

impl<P, T, Input> Freeze for Cloned<P, T, Input>
where P: Freeze,

§

impl<P, T, Input> RefUnwindSafe for Cloned<P, T, Input>
where P: RefUnwindSafe,

§

impl<P, T, Input> Send for Cloned<P, T, Input>
where P: Send,

§

impl<P, T, Input> Sync for Cloned<P, T, Input>
where P: Sync,

§

impl<P, T, Input> Unpin for Cloned<P, T, Input>
where P: Unpin,

§

impl<P, T, Input> UnsafeUnpin for Cloned<P, T, Input>
where P: UnsafeUnpin,

§

impl<P, T, Input> UnwindSafe for Cloned<P, T, Input>
where P: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V