Struct EnumeratedChunkPuller

pub struct EnumeratedChunkPuller<P>
where
    P: ChunkPuller,
{ /* private fields */ }

Chunk puller of an enumerated concurrent iterator; i.e., Enumerate

Trait Implementations

impl<P> ChunkPuller for EnumeratedChunkPuller<P>

where P: ChunkPuller,

type ChunkItem = (usize, <P as ChunkPuller>::ChunkItem)

Type of the element that the concurrent iterator yields.

type Chunk<'c> = EnumeratedChunk<<P as ChunkPuller>::Chunk<'c>> where Self: '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<Self::Chunk<'_>>

Pulls the next chunk from the connected concurrent iterator.

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.

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: