Struct MonoWaitGroup 

pub struct MonoWaitGroup(/* private fields */);

WaitGroup with a single non-clonable group token.

This variant is optimized for scenarios where there is exactly one worker task, and the group token cannot be cloned.

Cancellation safety

This future is cancellation safe.

It is also safe to poll again after completion.

let (wg, token) = MonoWaitGroup::new();
let mut wg = core::pin::pin!(wg);

assert!(!wg.is_done());

token.release();

wg.as_mut().await;
assert!(wg.is_done());

// It is safe to await again (re-poll)
wg.as_mut().await;
assert!(wg.is_done());

Implementations

impl MonoWaitGroup

pub fn new() -> (Self, MonoGroupToken)

Creates a new MonoWaitGroup and a single MonoGroupToken.

pub fn is_done(&self) -> bool

Checks if the MonoWaitGroup has completed.

This returns true if the MonoGroupToken has been dropped.

Trait Implementations

impl Debug for MonoWaitGroup

fn fmt(&self, __derive_more_f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Future for MonoWaitGroup

type Output = ()

The type of value produced on completion.

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

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.