Struct RansDecoderStream 

pub struct RansDecoderStream<S: EncoderVariantForS> { /* private fields */ }

rANS decoder stream for a specific variant S.

Owns the encoded data and keeps a persistent decode cursor (unit position + rANS state) across sequential decode calls. This matches Microsoft’s RansDecoderStream, where the raw decoder is initialized once in Open() and reused by every Decode call.

Implementations

impl<S: EncoderVariantForS> RansDecoderStream<S>

pub fn new() -> Self

Create a decoder stream (closed).

pub fn open_on(data: &[u8]) -> Self

Create a decoder stream opened on the given data.

pub fn is_open(&self) -> bool

Whether the stream is open (has data).

pub fn check_eof(&self) -> bool

Whether the current state can be at EOF.

EOF requires the source to be exhausted and the decoder state to be at LowerBound (or the stream to be unopened).

pub fn open(&mut self, data: &[u8])

Open the stream on new data, resetting the cursor.

pub fn close(&mut self)

Close the stream, releasing data.

pub fn decode_eof(&mut self) -> Result<(), EntropyError>

Check that decoding reached the end of the message and close on success.

pub fn decode( &mut self, decoder: &EntropyDecoder<S>, values: &mut [i32], indices: &[i32], ) -> Result<(), EntropyError>

Decode a batch of symbols from the stream, advancing the persistent cursor.

The first call initializes the raw decoder from the stream’s initial state; subsequent calls continue from the saved cursor.

pub fn bytes_consumed(&self) -> usize

Number of bytes consumed so far (unit position × unit size).

pub fn data(&self) -> &[u8]

The full stream data (borrowed).

Trait Implementations

impl<S: Debug + EncoderVariantForS> Debug for RansDecoderStream<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: EncoderVariantForS> Default for RansDecoderStream<S>

fn default() -> Self

Returns the “default value” for a type.