Struct Producer 

pub struct Producer<T> { /* private fields */ }

Publishes a sliding window of JSON records over a track.

An Encoder that owns its track: it writes each encoded frame and rolls a group whenever the encoder emits a header. When something else already owns the track, use the Encoder directly.

Cheaply clonable: clones share one underlying track and window, like other MoQ producers.

Implementations

impl<T> Producer<T>

pub fn new(track: Producer, config: ProducerConfig) -> Self

Create a producer that publishes to the given track.

pub fn consume(&self) -> Subscriber

Create a subscriber for the underlying track.

pub fn window(&self) -> Vec<Value>

The retained checkpoint suffix, oldest first.

This is the complete window unless ProducerConfig::checkpoint_records is set.

pub fn range(&self) -> Range<u64>

Absolute index of the oldest retained record, and of the next to be pushed.

pub fn pop(&mut self, count: u64) -> Result<()>

Drop count records from the front of the window.

A no-op when the window is already empty, and clamped to what it holds, so a caller can trim unconditionally.

pub fn finish(&mut self) -> Result<()>

Finish the track, closing any open group.

Borrows rather than consumes, matching snapshot and stream, so the handle stays usable afterwards (reads, a second finish). Writes after this fail with moq_net::Error::Closed.

impl<T: Serialize> Producer<T>

pub fn push(&mut self, value: &T) -> Result<()>

Append one record to the back of the window.

Trait Implementations

impl<T> Clone for Producer<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.