pub struct Max<P> { /* private fields */ }Implementations§
Trait Implementations§
Source§impl<P: ParallelPipe<Item>, Item> DistributedSink<Item> for Max<P>
impl<P: ParallelPipe<Item>, Item> DistributedSink<Item> for Max<P>
type Done = <<Max<P> as DistributedSink<Item>>::ReduceC as Reducer<<<Max<P> as DistributedSink<Item>>::ReduceB as Reducer<<<Max<P> as DistributedSink<Item>>::ReduceA as Reducer<<P as DistributedPipe<Item>>::Output>>::Done>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as DistributedPipe<Item>>::Output, Max<<P as DistributedPipe<Item>>::Output>, Inter>
type ReduceB = FolderSyncReducer<<<Max<P> as DistributedSink<Item>>::ReduceA as Reducer<<P as DistributedPipe<Item>>::Output>>::Done, Max<<P as DistributedPipe<Item>>::Output>, Inter>
type ReduceC = FolderSyncReducer<<<Max<P> as DistributedSink<Item>>::ReduceB as Reducer<<<Max<P> as DistributedSink<Item>>::ReduceA as Reducer<<P as DistributedPipe<Item>>::Output>>::Done>>::Done, Max<<P as DistributedPipe<Item>>::Output>, Final>
fn reducers(self) -> (P, Self::ReduceA, Self::ReduceB, Self::ReduceC)
Source§impl<P: ParallelPipe<Item>, Item> ParallelSink<Item> for Max<P>
impl<P: ParallelPipe<Item>, Item> ParallelSink<Item> for Max<P>
type Done = <<Max<P> as ParallelSink<Item>>::ReduceC as Reducer<<<Max<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, Max<<P as ParallelPipe<Item>>::Output>, Inter>
type ReduceC = FolderSyncReducer<<<Max<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, Max<<P as ParallelPipe<Item>>::Output>, Final>
fn reducers(self) -> (P, Self::ReduceA, Self::ReduceC)
Auto Trait Implementations§
impl<P> Freeze for Max<P>where
P: Freeze,
impl<P> RefUnwindSafe for Max<P>where
P: RefUnwindSafe,
impl<P> Send for Max<P>where
P: Send,
impl<P> Sync for Max<P>where
P: Sync,
impl<P> Unpin for Max<P>where
P: Unpin,
impl<P> UnsafeUnpin for Max<P>where
P: UnsafeUnpin,
impl<P> UnwindSafe for Max<P>where
P: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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