Type Definition unicycle::FuturesUnordered

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

A container for an unordered collection of Futures.

Examples

use tokio::time;
use std::time::Duration;

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

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

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

    println!("done!");
}

Implementations

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.

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

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Option<T::Output>>

Internal poll function for FuturesUnordered<T>.

type Item = T::Output

The output of the poll.