Struct Consumer 

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

Consumes a JSON value from a track, reconstructing it from snapshots and deltas.

Implementations

impl<T: DeserializeOwned> Consumer<T>

pub fn new(track: TrackConsumer) -> Self

Create a consumer reading from the given track subscriber.

pub async fn next(&mut self) -> Result<Option<T>>

where T: Unpin,

Get the next reconstructed value, or None once the track ends.

pub fn poll_next(&mut self, waiter: &Waiter) -> Poll<Result<Option<T>>>

Poll for the next reconstructed value, without blocking.

Jumps to the newest group, reads its snapshot, and applies deltas in order, yielding the reconstructed value after each frame. Switching to a newer group discards the older one.