Struct CollectiveHandle 

pub struct CollectiveHandle { /* private fields */ }

A handle to a non-blocking collective operation.

The collective runs asynchronously in a spawned task. Call wait() to block until it completes, or check is_finished() to poll.

If dropped without calling wait(), the background task is aborted to prevent writes to potentially-freed memory.

Implementations

impl CollectiveHandle

pub async fn wait(self) -> Result<()>

Wait for the collective to complete and propagate any error.

pub fn is_finished(&self) -> bool

Check if the collective has finished (non-blocking).

Trait Implementations

impl Drop for CollectiveHandle

fn drop(&mut self)

Executes the destructor for this type.