Struct ProcessedElementIterator 

pub struct ProcessedElementIterator { /* private fields */ }

Implementations

impl ProcessedElementIterator

pub fn new(path: PathBuf) -> Result<ProcessedElementIterator, CodecError>

Trait Implementations

impl Parallel for ProcessedElementIterator

type Item<'a> = ProcessedElement

fn for_each<F>(self, f: F)

where F: Fn(ProcessedElement) + Send + Sync,

Allows immutable linear traversal over the given iterator.

fn map_red<Map, Reduce, Identity, T>( self, map_op: Map, red_op: Reduce, ident: Identity, ) -> T

where Map: Fn(ProcessedElement) -> T + Send + Sync, Reduce: Fn(T, T) -> T + Send + Sync, Identity: Fn() -> T + Send + Sync, T: Send,

Allows for a map and reduce over the provided iterator.

fn par_red<Reduce, Identity, Combine, T>( self, fold_op: Reduce, combine: Combine, ident: Identity, ) -> T

where Reduce: Fn(T, ProcessedElement) -> T + Send + Sync, Identity: Fn() -> T + Send + Sync, Combine: Fn(T, T) -> T + Send + Sync, T: Send,

Allows for a reduce over the provided iterator, in parallel.