Struct Request 

pub struct Request { /* private fields */ }

A pending request for a broadcast to be served on demand.

Yielded by Dynamic::requested_broadcast. The requester is awaiting inside Consumer::request_broadcast; accept resolves it with a live broadcast (which the handler keeps producing into) and reject resolves it with an error. Dropping the request without either rejects it.

Implementations

impl Request

pub fn path(&self) -> &Path<'_>

The absolute path that was requested.

pub fn accept(self, broadcast: impl Consume<Consumer>)

Accept the request, resolving every awaiting requester with broadcast.

The caller keeps producing into broadcast (e.g. a relay proxying tracks from upstream); the requesters receive a consumer for it. Repeat requests for the path share the served broadcast for as long as it stays live.

pub fn reject(self, err: Error)

Reject the request, resolving every awaiting requester with err.

Trait Implementations

impl Drop for Request

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.