Struct futures_bounded::FuturesSet

pub struct FuturesSet<O> { /* private fields */ }

Represents a list of Futures.

Each future must finish within the specified time and the list never outgrows its capacity.

Implementations

impl<O> FuturesSet<O>

pub fn new(timeout: Duration, capacity: usize) -> Self

impl<O> FuturesSet<O>

pub fn try_push<F>(&mut self, future: F) -> Result<(), BoxFuture<'_, O>>where F: Future<Output = O> + Send + 'static,

Push a future into the list.

This method adds the given future to the list. If the length of the list is equal to the capacity, this method returns a error that contains the passed future. In that case, the future is not added to the set.

pub fn is_empty(&self) -> bool

pub fn poll_ready_unpin(&mut self, cx: &mut Context<'_>) -> Poll<()>

pub fn poll_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Result<O, Timeout>>