Struct Producer 

pub struct Producer { /* private fields */ }

Publishes encoded video frames as a moq track (avc3 / hev1 depending on the codec).

Built on the async side so the track is advertised (and the catalog registered) before the camera opens; this is what lets a subscriber trigger capture on demand. The moq_mux::codec importer for the codec handles catalog registration and framing.

Implementations

impl Producer

pub fn new( broadcast: Producer, catalog: Producer, codec: Codec, ) -> Result<Self, Error>

Publish a track for codec into broadcast, registering its rendition in catalog. The frames fed to publish must be in that codec’s framing (the matching Encoder emits it).

pub fn demand(&self) -> Demand

A watch-only handle to the track’s subscriber demand, created eagerly so subscription state is observable before any frames arrive. Watch it via used / unused.

pub fn publish(&mut self, encoded: &[Encoded]) -> Result<(), Error>

Publish already-encoded frames, each at its own timestamp. Each frame is one whole access unit in the producer’s codec framing.

pub fn discontinuity(&mut self) -> Result<(), Error>

Mark a break in the published timeline: whatever is published next does not continue what came before.

Call this when the encoder stops rather than merely pausing between frames – a capture that goes idle, a source switch, anything that will resume on a re-anchored clock. See Producer::discontinuity for what the marker buys a consumer.

pub fn finish(self) -> Result<(), Error>

Finalize the track.

Consumes the producer: nothing can be published after the track ends, so this is the last call rather than one leaving a dead producer in your hands.

pub fn abort(self, err: Error)

Abort the track with err instead of finishing it cleanly, so subscribers see the real cause rather than moq_net::Error::Dropped.

Consumes the producer, like finish.