Struct Leased 

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

A signal-like value whose producer can wait until all outstanding readers finish.

Leased counts live claims; drain blocks until the count reaches zero, which is used to hold a producer’s stop until consumers are done.

Implementations

impl<T> Leased<T>

pub const fn new(inner: T) -> Self

Wrap inner as a leased value.

pub fn leases(&self) -> u32

Return the number of live leases.

pub fn is_drained(&self) -> bool

Return true if the value has been drained.

pub async fn drain(&self)

Close the value to new leases and wait until all current leases drop.

pub fn reopen(&self)

Reopen the value to new leases after a previous drain.

pub fn lease(&'static self) -> Option<Lease<T>>

Acquire a live lease, or None if the value is drained.

Trait Implementations

impl<T> Deref for Leased<T>

The wrapper is transparent to everything that is not a lease.

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &T

Dereferences the value.

impl<T: Observable> Observable for Leased<T>

Available on crate feature coupling-observe only.

Polling a wrapped signal is polling what it wraps, so an observed entry keeps working when a signal gains a lease count.

fn change_token(&self) -> u32

Return a token that changes when the signal is written.