Type Definition unicycle::FuturesUnordered

type FuturesUnordered<T> = Unordered<T, Futures>;

A container for an unordered collection of Futures.

Examples

use tokio::{stream::StreamExt as _, time};
use std::time::Duration;

#[tokio::main]
async fn main() {
    let mut futures = unicycle::FuturesUnordered::new();

    futures.push(time::delay_for(Duration::from_secs(2)));
    futures.push(time::delay_for(Duration::from_secs(3)));
    futures.push(time::delay_for(Duration::from_secs(1)));

    while let Some(_) = futures.next().await {
        println!("tick");
    }

    println!("done!");
}

Methods

impl<T> FuturesUnordered<T>

pub fn new() -> Self

Construct a new, empty FuturesUnordered.

Examples

use unicycle::FuturesUnordered;

let mut futures = FuturesUnordered::new();
assert!(futures.is_empty());

futures.push(async { 42 });

Trait Implementations

impl<T> FromIterator<T> for FuturesUnordered<T> where
    T: Future, 

fn from_iter<I: IntoIterator<Item = T>>(iter: I) -> Self

Creates a value from an iterator.