Struct Dispatcher 

pub struct Dispatcher<T> { /* private fields */ }

Implementations

impl<T> Dispatcher<T>

pub fn new(scheduler: AsyncScheduler<T>, max_in_flight: usize) -> Self

Creates a dispatcher with bounded in-flight handler executions.

impl<T: Send + 'static> Dispatcher<T>

pub async fn run<F, Fut>(&self, handler: F)

where F: Fn(DequeueItem<T>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + 'static,

Runs the dequeue loop and executes each task with the provided async handler.