Struct BroadcastConsumer 

pub struct BroadcastConsumer { /* private fields */ }

Subscribe to arbitrary broadcast/tracks.

Implementations

impl BroadcastConsumer

pub fn subscribe_track(&self, track: &Track) -> Result<TrackConsumer, Error>

Subscribe to a track on this broadcast.

Reuses an existing producer if one is already publishing the track; otherwise queues a new dynamic request that the broadcast’s producer will service via BroadcastDynamic::requested_track. Returns Error::NotFound if the broadcast has no dynamic producer to handle requests.

pub async fn closed(&self) -> Error

Block until the broadcast is closed and return the cause.

Returns Error::Dropped if every producer was dropped without an explicit abort, or the abort error supplied by BroadcastProducer::abort.

pub fn is_closed(&self) -> bool

Returns true if every BroadcastProducer has been dropped.

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

Register a conducer::Waiter that fires when the broadcast closes.

Returns Poll::Ready if already closed, otherwise Poll::Pending after arming the waiter. Useful for composing close-detection into a larger poll without spawning a task per broadcast.

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

Check if this is the exact same instance of a broadcast.

Trait Implementations

impl Clone for BroadcastConsumer

fn clone(&self) -> BroadcastConsumer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Deref for BroadcastConsumer

type Target = Broadcast

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.