Struct Consumer 

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

Consumes a sliding window of JSON records from a track, yielding one event per change.

A Decoder that owns its track: it reads groups, starts a cold DEFLATE window at each boundary, and turns each group’s header into just the changes this reader has not been told about. When something else already owns the track, use the Decoder directly.

Group rolls never surface. A publisher rolls for compression’s sake, and a header restating the window yields nothing for records already delivered, so this reads as one continuous stream of Events regardless of how the publisher framed them.

Implementations

impl<T: DeserializeOwned> Consumer<T>

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

Create a consumer reading from the given track subscriber.

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

Absolute index of the oldest record in the window, and of the next to arrive.

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

where T: Unpin,

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

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

Poll for the next event, without blocking.