Skip to main content

EgressSource

moq_rtc::egress

Struct EgressSource

pub struct EgressSource { /* private fields */ }

Expand description

Holds the broadcast + catalog and spawns per-rendition pump tasks.

Implementations§

impl EgressSource

pub async fn new(broadcast: BroadcastConsumer) -> Result<Self>

Subscribe to the broadcast’s catalog and wait for the first snapshot.

The session loop drives the pumps via the returned channel; the caller hands EgressSource to Session::egress which takes the receiver via Self::take_writes.

pub fn take_writes(&mut self) -> Receiver<WriteRequest>

One-shot extractor for the write-request receiver. The session loop awaits on this to forward frames into str0m.

pub fn on_track( &mut self, mid: Mid, codec: Codec, pt: Pt, clock_rate: Frequency, ) -> Result<()>

Spawn a pump task for a newly added (sendonly) media line.

mid and pt come from str0m’s negotiated state; clock_rate is the codec’s negotiated RTP clock. The pump subscribes to a matching catalog rendition and forwards every frame as a WriteRequest.

pub fn catalog_codecs(&self) -> Vec<Codec>

Codecs present in the catalog, used by the SDP-offer side (client publish) to declare what we have. For v1: the union of audio + video codecs across all renditions.

Auto Trait Implementations§

impl Freeze for EgressSource

impl RefUnwindSafe for EgressSource

impl Send for EgressSource

impl Sync for EgressSource

impl Unpin for EgressSource

impl UnsafeUnpin for EgressSource

impl UnwindSafe for EgressSource

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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

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> MaybeSend for T
where T: Send,

impl<T> MaybeSync for T
where T: Sync,

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

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T> Same for T

type Output = T

Should always be Self

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<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

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