Struct Subscribe 

pub struct Subscribe(/* private fields */);

A pending SRT subscribe (egress), waiting on the caller to authorize it.

The viewing counterpart of Publish: inspect resource / stream_id, then accept to serve a broadcast from an origin down to the caller, or reject it. Dropping it without either drops the connection.

Implementations

impl Subscribe

pub fn resource(&self) -> &str

The resource name to route on (the stream id’s r= value, or the raw stream id).

pub fn stream_id(&self) -> Option<&str>

The raw SRT stream id, if the client supplied one.

As with a publish, an embedder can treat this as a token to authorize the viewer.

pub fn peer(&self) -> SocketAddr

The remote peer address.

pub async fn accept(self, origin: &Consumer, path: impl AsPath) -> Result<()>

Accept the subscribe: resolve the broadcast at path in origin, re-mux it to MPEG-TS, and stream it down to the caller until either side ends.

Waits for the broadcast to be announced (so a caller may connect before the publisher), cancelling cleanly if the caller disconnects first. This future resolves when playback ends, so callers usually run it on its own task.

pub async fn reject(self) -> Result<()>

Reject the subscribe, sending the client a Forbidden rejection.