Skip to main content

WhepResource

arcly_stream::protocol::webrtc

Struct WhepResource

pub struct WhepResource { /* private fields */ }

Available on crate features ingest and webrtc only.

Expand description

An accepted WHEP connection: streams one live stream out to the viewer as RTP until the stream ends or the peer disconnects.

Implementations§

impl WhepResource

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

Drive egress: subscribe to the stream, replay the cached config + GOP for an instant start, then packetize and send every published video frame. Returns when the stream closes or the subscription lags out.

The RTP payload format is selected from the stream’s video codec: H.264 (RFC 6184) and H.265 (RFC 7798) are packetized; other video codecs are skipped with a single warning per connection, and audio is skipped.

Auto Trait Implementations§

impl !Freeze for WhepResource

impl !RefUnwindSafe for WhepResource

impl !UnwindSafe for WhepResource

impl Send for WhepResource

impl Sync for WhepResource

impl Unpin for WhepResource

impl UnsafeUnpin for WhepResource

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more