Struct AbortablePool 

pub struct AbortablePool<T> { /* private fields */ }

An unordered pool of futures that can be individually aborted.

Each future added to the pool returns an Aborter. When the aborter is dropped, the associated future is aborted.

Note: This pool is not thread-safe and should not be used across threads without external synchronization.

Implementations

impl<T: Send> AbortablePool<T>

pub fn len(&self) -> usize

Returns the number of futures in the pool.

pub fn is_empty(&self) -> bool

Returns true if the pool is empty.

pub fn push( &mut self, future: impl Future<Output = T> + Send + 'static, ) -> Aborter

Adds a future to the pool and returns an Aborter that can be used to abort it.

The future must be 'static and Send to ensure it can be safely stored and executed. When the returned Aborter is dropped, the future will be aborted.

pub fn next_completed( &mut self, ) -> SelectNextSome<'_, FuturesUnordered<Pin<Box<dyn Future<Output = Result<T, Aborted>> + Send>>>>

Returns a future that resolves to the next future in the pool that resolves.

If the pool is empty, the future will never resolve. Returns Ok(T) for successful completion or Err(Aborted) for aborted futures.

Trait Implementations

impl<T: Send> Default for AbortablePool<T>

fn default() -> Self

Returns the “default value” for a type.