Struct Dynamic 

pub struct Dynamic { /* private fields */ }

Handles on-demand track creation for a broadcast.

When a consumer requests a track that doesn’t exist, the dynamic producer picks up the request via Self::requested_track and either track::Request::accepts it with a concrete track::Info or track::Request::rejects it. Dropped when no longer needed; pending requests are automatically aborted.

Implementations

impl Dynamic

pub fn info(&self) -> &Info

The broadcast’s static metadata, fixed when it was created.

pub fn poll_requested_track( &mut self, waiter: &Waiter, ) -> Poll<Result<Request, Error>>

Poll for the next consumer-requested track, without blocking.

Returns Error::Closed once the broadcast has ended, so a serving loop knows to stop and release its handle.

pub async fn requested_track(&mut self) -> Result<Request, Error>

Block until a consumer requests a track, returning a track::Request to serve.

pub fn consume(&self) -> Consumer

Create a consumer that can subscribe to tracks in this broadcast.

pub async fn closed(&self) -> Error

Block until the broadcast ends, by Producer::close or every producer dropping.

Returns Error::Dropped, or the error passed to the deprecated abort.

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

Poll-based variant of Self::closed.

pub fn is_clone(&self, other: &Self) -> bool

Return true if this is the same broadcast instance.

Trait Implementations

impl Clone for Dynamic

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.