Expand description
Concurrent work queue helpers
Structs§
- Error type indicating a task failed because the queue was dropped before completing the task.
- A work queue that processes a configurable number of tasks concurrently, deduplicating work with the same key.
- A clonable handle to the work queue. When all clones of WorkSender are dropped, the queue will process all remaining requests and terminate its output stream.
Traits§
- Trait for merging context for work tasks with the same key.
- Trait that creates a work future from a key and context.
Functions§
- Creates an unbounded queue of work tasks that will execute up to
concurrencyworkers at once.