Struct FutureStream 

pub struct FutureStream<T: Send> { /* private fields */ }

Stream of multiple Futures

A FutureStream can be used to wait for multiple Futures, and return them incrementally as they are resolved.

It implements an iterator over completed Futures, and can be constructed from an iterator of Futures.

May be cloned and the clones passed to other threads so that Futures may be added from multiple threads.

Implementations

impl<T: Send> FutureStream<T>

pub fn new() -> FutureStream<T>

pub fn add(&self, fut: Future<T>)

where T: 'static,

Add a Future to the stream.

pub fn outstanding(&self) -> usize

Return number of outstanding Futures.

pub fn waiter<'fs>(&'fs self) -> FutureStreamWaiter<'fs, T>

Return a singleton FutureStreamWaiter. If one already exists, block until it is released.

pub fn try_waiter<'fs>(&'fs self) -> Option<FutureStreamWaiter<'fs, T>>

Return a singleton FutureStreamWaiter. Returns None if one already exists.

pub fn poll(&self) -> Option<Future<T>>

Return a resolved Future if any, but don’t wait for more to resolve.

pub fn wait(&self) -> Option<Future<T>>

Return resolved Futures. Blocks if there are outstanding Futures which are not yet resolved. Returns None when there are no more outstanding Futures.

Trait Implementations

impl<T: Clone + Send> Clone for FutureStream<T>

fn clone(&self) -> FutureStream<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Send + 'static> FromIterator<Future<T>> for FutureStream<T>

fn from_iter<I>(iterator: I) -> Self

where I: IntoIterator<Item = Future<T>>,

Creates a value from an iterator.

impl<'a, T: Send + 'a> IntoIterator for &'a FutureStream<T>

type Item = T

The type of the elements being iterated over.

type IntoIter = FutureStreamIter<'a, T>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.