Struct OriginDynamic 

pub struct OriginDynamic { /* private fields */ }

Picks up OriginConsumer::request_broadcast calls for paths that are not announced.

The origin-level analogue of crate::BroadcastDynamic: where that serves tracks on demand within a broadcast, this serves whole broadcasts on demand within an origin. A relay uses it as a fallback router, fetching a broadcast from upstream only when a downstream consumer asks for an exact path that nobody announced.

Served broadcasts are deliberately not announced, so they never appear in OriginConsumer::announced. Drop this handle (and every clone) to reject the requests still waiting to be served.

Implementations

impl OriginDynamic

pub fn info(&self) -> &Origin

The origin this handler belongs to.

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

Poll for the next requested broadcast, without blocking.

pub async fn requested_broadcast(&mut self) -> Result<BroadcastRequest, Error>

Block until a consumer requests an unannounced broadcast, returning a BroadcastRequest to serve.

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

Returns the prefix that is automatically stripped from requested paths.

Trait Implementations

impl Clone for OriginDynamic

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 OriginDynamic

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.