pub struct CopiedChunkPuller<'i, T, P>{ /* private fields */ }
Expand description
Chunk puller of a copied concurrent iterator; i.e., ConIterCopied
Trait Implementations§
Source§impl<'i, T, P> ChunkPuller for CopiedChunkPuller<'i, T, P>
impl<'i, T, P> ChunkPuller for CopiedChunkPuller<'i, T, P>
Source§type Chunk<'c> = Copied<<P as ChunkPuller>::Chunk<'c>>
where
Self: 'c
type Chunk<'c> = Copied<<P as ChunkPuller>::Chunk<'c>> where Self: 'c
Type of the pulled chunks which implements
ExactSizeIterator
.Source§fn chunk_size(&self) -> usize
fn chunk_size(&self) -> usize
Target length of the pulled chunks. Read more
Source§fn pull(&mut self) -> Option<Self::Chunk<'_>>
fn pull(&mut self) -> Option<Self::Chunk<'_>>
Pulls the next chunk from the connected concurrent iterator. Read more
Source§fn pull_with_idx(&mut self) -> Option<(usize, Self::Chunk<'_>)>
fn pull_with_idx(&mut self) -> Option<(usize, Self::Chunk<'_>)>
Pulls the next chunk from the connected concurrent iterator together with the index
of the first element of the chunk. Read more
Source§fn flattened<'c>(self) -> FlattenedChunkPuller<'c, Self> ⓘwhere
Self: Sized,
fn flattened<'c>(self) -> FlattenedChunkPuller<'c, Self> ⓘwhere
Self: Sized,
Converts the
ChunkPuller
into a FlattenedChunkPuller
which is still connected to
and pulls its elements from the same concurrent iterator; while allowing for: Read moreSource§fn flattened_with_idx<'c>(self) -> FlattenedEnumeratedChunkPuller<'c, Self> ⓘwhere
Self: Sized,
fn flattened_with_idx<'c>(self) -> FlattenedEnumeratedChunkPuller<'c, Self> ⓘwhere
Self: Sized,
Converts the
ChunkPuller
into a FlattenedEnumeratedChunkPuller
which is still connected to
and pulls its elements from the same concurrent iterator; while allowing for: Read moreSource§impl<'i, T, P> From<P> for CopiedChunkPuller<'i, T, P>
impl<'i, T, P> From<P> for CopiedChunkPuller<'i, T, P>
Auto Trait Implementations§
impl<'i, T, P> Freeze for CopiedChunkPuller<'i, T, P>where
P: Freeze,
impl<'i, T, P> RefUnwindSafe for CopiedChunkPuller<'i, T, P>where
P: RefUnwindSafe,
impl<'i, T, P> Send for CopiedChunkPuller<'i, T, P>where
P: Send,
impl<'i, T, P> Sync for CopiedChunkPuller<'i, T, P>where
P: Sync,
impl<'i, T, P> Unpin for CopiedChunkPuller<'i, T, P>where
P: Unpin,
impl<'i, T, P> UnwindSafe for CopiedChunkPuller<'i, T, 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