Struct Consumer 

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

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

The log rides a single group, so this reads that group’s frames in order; one record per frame.

Implementations

impl<T: DeserializeOwned> Consumer<T>

pub fn new(track: TrackConsumer, 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.