Trait Executor 

pub trait Executor: Send + Sync {
    // Required methods
    fn parallelism(&self) -> usize;
    fn for_each_chunk(&self, workers: usize, chunks: &(dyn ChunkSource + Sync));
}

Required Methods

fn parallelism(&self) -> usize

fn for_each_chunk(&self, workers: usize, chunks: &(dyn ChunkSource + Sync))

workers is a request; each worker drains chunks until run_next is false.

Implementors

impl Executor for Sequential