Struct Decoder 

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

Decodes JSON records from frame payloads, sharing one DEFLATE window across the log.

The track-free core of Consumer, and the mirror of Encoder. Payloads must be fed in the order they were encoded, since each one builds on the window the earlier ones left behind. Call reset at a group boundary, matching the encoder.

Implementations

impl<T> Decoder<T>

pub fn new(config: ConsumerConfig) -> Self

Create a decoder with a cold window.

pub fn reset(&mut self)

Start a cold DEFLATE window, for a caller that has just moved to a new group.

impl<T: DeserializeOwned> Decoder<T>

pub fn decode(&mut self, payload: &[u8]) -> Result<T>

Decode the next frame payload back into a record.