Struct WorkDispatcher 

pub struct WorkDispatcher<P: Producer, C: Processor<Item = P::Item>> { /* private fields */ }

The WorkDispatcher orchestrates the entire concurrent dispatcher.

Implementations

impl<P, C> WorkDispatcher<P, C>

where P: Producer + Send + 'static, P::Item: Send + 'static, C: Processor<Item = P::Item> + Clone + Send + Sync + 'static,

pub fn new(producer: P, processor: C, context: C::Context) -> Self

Creates a new WorkDispatcher with a producer, a processor, and a shared context.

pub fn workers(self, count: usize) -> Self

Sets the number of concurrent worker tasks. Defaults to the number of logical CPU cores.

pub fn buffer(self, size: usize) -> Self

Sets the size of the bounded channel connecting the producer and processors. Defaults to num_workers * 100.

pub async fn run(self) -> Result<()>

Runs the entire dispatcher and waits for it to complete.