Struct RansEncoderStream 

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

rANS encoder stream for a specific variant S.

Keeps a persistent raw encoder state across push() calls. flush() writes the final state and yields the encoded message; the stream can then be reused. reset() aborts the current session.

Implementations

impl<S: EncoderVariantForS> RansEncoderStream<S>

pub fn new() -> Self

Create a new encoder stream.

pub fn is_initialized(&self) -> bool

Whether the stream has an active encoder session.

pub fn push( &mut self, encoder: &EntropyEncoder<S>, indices: &[i32], values: &[i32], ) -> Result<(), EntropyError>

Push an entropy-encoded batch onto the stream.

Encodes values using the given encoder’s PMF, continuing the persistent raw encoder state. Matches EntropyEncoder::push in Python and IEntropyEncoderImpl::Encode(stream, indices, values).

pub fn flush(&mut self) -> Result<Vec<u8>, EntropyError>

Flush the current session and return the encoded message.

After flush, the stream is reset for reuse. Returns an error if no data has been pushed (matching the Python flush which raises on empty output).

pub fn reset(&mut self)

Abort the current session, discarding all pushed data.

Trait Implementations

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

where S::RawEnc: Debug,

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

Formats the value using the given formatter.

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

fn default() -> Self

Returns the “default value” for a type.