Struct amadeus_core::par_sink::SampleUnstable [−][src]
#[must_use]pub struct SampleUnstable<P> { /* fields omitted */ }
Implementations
impl<P> SampleUnstable<P>
[src]
impl<P> SampleUnstable<P>
[src]Trait Implementations
impl<P: ParallelPipe<Item>, Item> DistributedSink<Item> for SampleUnstable<P> where
P::Output: Send + 'static,
[src]
impl<P: ParallelPipe<Item>, Item> DistributedSink<Item> for SampleUnstable<P> where
P::Output: Send + 'static,
[src]type Done = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<P::Output>>::Done>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<P::Output, SampleUnstableFolder, Inter>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<P::Output>>::Done, SumFolder<SASampleUnstable<P::Output>>, Inter>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<P::Output>>::Done>>::Done, SumFolder<SASampleUnstable<P::Output>>, Final>
fn reducers(self) -> (P, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<P: ParallelPipe<Item>, Item> ParallelSink<Item> for SampleUnstable<P> where
P::Output: Send + 'static,
[src]
impl<P: ParallelPipe<Item>, Item> ParallelSink<Item> for SampleUnstable<P> where
P::Output: Send + 'static,
[src]type Done = <Self::ReduceC as Reducer<<Self::ReduceA as Reducer<P::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<P::Output, SampleUnstableFolder, Inter>
type ReduceC = FolderSyncReducer<<Self::ReduceA as Reducer<P::Output>>::Done, SumFolder<SASampleUnstable<P::Output>>, Final>
fn reducers(self) -> (P, Self::ReduceA, Self::ReduceC)
[src]
Auto Trait Implementations
impl<P> RefUnwindSafe for SampleUnstable<P> where
P: RefUnwindSafe,
P: RefUnwindSafe,
impl<P> Send for SampleUnstable<P> where
P: Send,
P: Send,
impl<P> Sync for SampleUnstable<P> where
P: Sync,
P: Sync,
impl<P> Unpin for SampleUnstable<P> where
P: Unpin,
P: Unpin,
impl<P> UnwindSafe for SampleUnstable<P> where
P: UnwindSafe,
P: UnwindSafe,
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,