Struct Consumer 

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

Consumes an ordered log of JSON records from a track, yielding every record in order.

A Decoder that owns its track: it reads one record per frame, in order, and starts the decoder on a cold window at each group boundary. A Producer writes the whole log into one group, but a publisher that rolls its own (the way an Encoder desync is cleared) is read here too. When something else already owns the track, use the Decoder directly.

Implementations

impl<T: DeserializeOwned> Consumer<T>

pub fn new(track: Subscriber, config: ConsumerConfig) -> Self

Create a consumer reading from the given track subscriber.

Set ConsumerConfig::compression to read a track written by a producer with ProducerConfig::compression on.

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

where T: Unpin,

Get the next record, or None once the track ends.

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

Poll for the next record, without blocking.