Struct HandleRcVec

pub struct HandleRcVec<T: Unpin>(Arc<UnsafeCell<Vec<JoinHandle<T>>>>);

A container for managing a collection of asynchronous task join handles.

This structure encapsulates a reference-counted, mutable vector of asynchronous task handles, enabling concurrent polling of multiple tasks. Its design allows shared ownership and in-place mutation of the task collection without requiring external synchronization, supporting operations that extend or poll the set of join handles as part of asynchronous execution workflows.

Tuple Fields

0: Arc<UnsafeCell<Vec<JoinHandle<T>>>>

Implementations

impl<T: Unpin> HandleRcVec<T>

pub fn new() -> Self

Creates and returns a new instance of the container for asynchronous task handles.

Constructs an empty container by encapsulating an empty vector within an Arc and UnsafeCell, thereby enabling shared mutable access suitable for concurrent asynchronous operations.

pub fn extend_iter(&self, v: impl Iterator<Item = JoinHandle<T>>)

Extends the internal collection with join handles obtained from the provided iterator. This method iterates over each join handle from the iterator and appends it into the underlying storage, making the join handles available for future asynchronous polling.

pub fn len(&self) -> usize

Returns the number of join handles stored in the underlying collection. This method accesses the internal vector unsafely to determine its length, providing a simple way to query how many tasks have been added.

Trait Implementations

impl<T: Unpin> Clone for HandleRcVec<T>

fn clone(&self) -> Self

Clones the join handle collection by duplicating its internal shared pointer.

This method produces a new instance that shares the same underlying join handle storage, enabling multiple owners of the asynchronous task collection without copying the actual handles.

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

Performs copy-assignment from source.

impl<T: Unpin> Default for HandleRcVec<T>

fn default() -> Self

Returns a new default instance by invoking the primary constructor.

This method serves as a convenience alias for creating a default instance, allowing integration with traits or patterns that rely on default initialization. It encapsulates the functionality of the constructor without exposing implementation details.

impl<T: Unpin> Future for HandleRcVec<T>

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Polls a collection of asynchronous tasks and returns the output of the first task that is complete.

This method iterates over the stored join handles and evaluates each one to determine if its associated task has finished, returning the completed result if available. If none of the tasks are ready, it returns a pending status.

type Output = T

The type of value produced on completion.