Struct futures_bounded::FuturesTupleSet

pub struct FuturesTupleSet<O, D> { /* private fields */ }

Represents a list of tuples of a Future and an associated piece of data.

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

Implementations

impl<O, D> FuturesTupleSet<O, D>

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

impl<O, D> FuturesTupleSet<O, D>

where O: 'static,

pub fn try_push<F>( &mut self, future: F, data: D ) -> Result<(), (BoxFuture<'_, O>, D)>

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 len(&self) -> usize

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>, D)>