Struct unicycle::Unordered

pub struct Unordered<F> where
    F: Future,  { /* fields omitted */ }

A container for an unordered collection of Futures.

Methods

impl<F> Unordered<F> where
    F: Future, 

pub fn new() -> Self

Construct a new, empty Unordered.

pub fn is_empty(&self) -> bool

Test if the collection of futures is empty.

pub fn push(&mut self, future: F)

Add the given future to the Unordered stream.

Newly added futures are guaranteed to be polled, but there is no guarantee in which order this will happen.

Trait Implementations

impl<F> Default for Unordered<F> where
    F: Future, 

fn default() -> Self

Returns the "default value" for a type.

impl<F> Drop for Unordered<F> where
    F: Future, 

fn drop(&mut self)

Executes the destructor for this type.

impl<F> Send for Unordered<F> where
    F: Future, 

impl<F> Stream for Unordered<F> where
    F: Future, 

type Item = F::Output

Values yielded by the stream.

fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<F> Sync for Unordered<F> where
    F: Future, 

impl<F> Unpin for Unordered<F> where
    F: Future,