Struct ClonedChunkPuller 

pub struct ClonedChunkPuller<'i, T, P>
where
    T: Clone + 'i,
    P: ChunkPuller<ChunkItem = &'i T>,
{ /* private fields */ }

Chunk puller of a cloned concurrent iterator; i.e., ConIterCloned

Trait Implementations

impl<'i, T, P> ChunkPuller for ClonedChunkPuller<'i, T, P>

where T: Clone + 'i, P: ChunkPuller<ChunkItem = &'i T>,

type ChunkItem = T

Type of the element that the concurrent iterator yields.

type Chunk<'c> = Cloned<<P as ChunkPuller>::Chunk<'c>> where ClonedChunkPuller<'i, T, P>: 'c

Type of the pulled chunks which implements ExactSizeIterator.

fn chunk_size(&self) -> usize

Target length of the pulled chunks.

fn pull( &mut self, ) -> Option<<ClonedChunkPuller<'i, T, P> as ChunkPuller>::Chunk<'_>>

Pulls the next chunk from the connected concurrent iterator.

fn pull_with_idx( &mut self, ) -> Option<(usize, <ClonedChunkPuller<'i, T, P> as ChunkPuller>::Chunk<'_>)>

Pulls the next chunk from the connected concurrent iterator together with the index of the first element of the chunk.

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:

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:

impl<'i, T, P> From<P> for ClonedChunkPuller<'i, T, P>

where T: Clone + 'i, P: ChunkPuller<ChunkItem = &'i T>,

fn from(puller: P) -> ClonedChunkPuller<'i, T, P>

Converts to this type from the input type.