Struct AsyncTaskQueue 

pub struct AsyncTaskQueue { /* private fields */ }

An asynchronous task queue.

Simulates a queue of pending async IO tasks identified by integer handles.

Implementations

impl AsyncTaskQueue

pub fn new() -> Self

Create an empty task queue.

pub fn enqueue(&mut self, description: impl Into<String>) -> usize

Enqueue a new task, returning its handle.

pub fn complete_next(&mut self, result: impl Into<String>) -> Option<usize>

Complete the next pending task with the given result.

pub fn result_of(&self, id: usize) -> Option<&str>

Get the result of a completed task.

pub fn pending_count(&self) -> usize

Number of pending tasks.

pub fn completed_count(&self) -> usize

Number of completed tasks.

pub fn is_complete(&self, id: usize) -> bool

Check if a task has completed.

Trait Implementations

impl Default for AsyncTaskQueue

fn default() -> Self

Returns the “default value” for a type.