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 was deliberately ended (Producer::finish or aborted), 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 is closed, by Producer::finish, Producer::abort, or every producer dropping, returning the cause.

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

Poll until the broadcast closes; ready with the cause: the error passed to Producer::abort, or Error::Dropped for a Producer::finish or a dropped producer (check Consumer::is_finished to tell those apart).

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.

impl Drop for Dynamic

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.