Struct Producer 

pub struct Producer { /* private fields */ }

The authorizing side of a lease: applies new grants and revokes.

Dropping it revokes with Reason::Dropped unless the lease already ended.

Implementations

impl Producer

pub fn new(grant: Grant) -> (Self, Consumer)

Start a lease on grant, returning both handles.

pub fn update(&self, grant: Grant)

Replace the grant, waking the consumer. A no-op once the lease ended.

pub fn revoke(self, reason: Reason) -> Reason

End the lease with reason, consuming the handle, and return the reason the lease ended with: reason, or the consumer’s if it closed first.

pub fn poll_closed(&self, waiter: &Waiter) -> Poll<(Reason, Bytes)>

Poll for the lease ending, from either side: why it ended, and the totals the session reported. A producer-side revoke, or a drop, reports zero bytes.

pub async fn closed(&self) -> (Reason, Bytes)

Wait for the lease to end, from either side.

pub fn poll_revalidate(&self, waiter: &Waiter) -> Poll<()>

Poll until at least one re-check has been asked since the last observation. A burst of asks resolves once.

pub async fn revalidate_requested(&self)

Wait until a re-check has been asked since the last observation.

Trait Implementations

impl Debug for Producer

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

Formats the value using the given formatter.

impl Drop for Producer

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.