Struct TaskQueue 

pub struct TaskQueue { /* private fields */ }

An aggregator of async work that can be used to observe the moment when all the aggregated work is completed. It is similar to tokio’s JoinSet, but is relatively constrained and also works on wasm32-unknown-unknown. Unlike JoinSet, the results can not be observed individually.

let mut task_queue = TaskQueue::default();
for i in 0..10 {
    task_queue.spawn(async move {
        println!("{}", i);
        Ok(())
    });
}
task_queue.join().await?;

Implementations

impl TaskQueue

pub fn spawn<F>(&mut self, future: F)

where F: Future<Output = Result<()>> + Send + 'static,

Queue a future to be spawned in the local executor. All queued futures will be polled to completion before the TaskQueue can be joined.

pub async fn join(&mut self) -> Result<()>

Returns a future that finishes when all queued futures have finished.

Trait Implementations

impl Default for TaskQueue

fn default() -> TaskQueue

Returns the “default value” for a type.