Struct CapacityChanged 

pub struct CapacityChanged { /* private fields */ }

A release in this creator’s lane may have freed a slot or made a retained endpoint rearmable. This is a hint, not a reservation: retry the operation.

Construct before retrying a failed create/rearm, then await only if the retry still cannot proceed. Registration is armed at construction, and dropping the observer removes it without touching streams or their owners. Multiple callers may observe the same creator lane independently.

Trait Implementations

impl Drop for CapacityChanged

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Future for CapacityChanged

type Output = Result<(), Error>

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.