Struct Producer 

pub struct Producer { /* private fields */ }

Produces bandwidth estimates, notifying consumers when the value changes.

Implementations

impl Producer

pub fn new() -> Self

Create a fresh producer with no current estimate.

pub fn set(&self, bitrate: Option<u64>) -> Result<()>

Set the current bandwidth estimate in bits per second.

pub fn consume(&self) -> Consumer

Create a new consumer for the bandwidth estimate.

pub fn abort(&self, err: Error) -> Result<()>

Close the producer with an error, notifying all consumers.

pub async fn closed(&self)

Block until the channel is closed.

pub async fn unused(&self) -> Result<()>

Block until there are no active consumers.

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

Poll until there are no active consumers. Errors if the channel closes first.

pub async fn used(&self) -> Result<()>

Block until there is at least one active consumer.

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

Poll until at least one active consumer exists. Errors if the channel closes first.

Trait Implementations

impl Clone for Producer

fn clone(&self) -> Producer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Producer

fn default() -> Self

Returns the “default value” for a type.