Struct Producer 

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

Publishes a JSON value over a track, choosing snapshots and deltas automatically.

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

Implementations

impl<T> Producer<T>

pub fn consume(&self) -> TrackConsumer

Create a subscriber for the underlying track.

impl<T: Serialize> Producer<T>

pub fn new(track: TrackProducer, config: Config) -> Self

Create a producer that publishes to the given track.

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

Publish a new value, emitting a snapshot or a delta automatically.

Does nothing if the value is unchanged from the previous publish.

pub fn lock(&mut self) -> Guard<'_, T>

where T: Default + DeserializeOwned,

Lock the current value for in-place editing, publishing on drop.

The returned Guard derefs to the last-published value (or T::default() if nothing has been published yet). Editing it through DerefMut marks the guard dirty; when a dirty guard drops it publishes the result, a no-op if unchanged.

This is the counterpart to a callback: hold the guard, mutate, drop. The guard holds the producer’s lock for its lifetime, so independent owners are serialized: each one starts from the latest value and their changes compose instead of clobbering. Don’t hold a guard across an .await, since that keeps the lock held while suspended.

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

Finish the track, closing any open group.

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.