Identity

amadeus_core::par_stream

Struct Identity 

Source 
pub struct Identity;

Trait Implementations§

Source§

impl Clone for Identity

Source§

fn clone(&self) -> Identity

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for Identity

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl<Item> DistributedPipe<Item> for Identity

Source§

type Output = Item

Source§

type Task = IdentityTask

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<Item> ParallelPipe<Item> for Identity

Source§

type Output = Item

Source§

type Task = IdentityTask

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,

Source§

impl Copy for Identity

Auto Trait Implementations§

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<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
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> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
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