Struct constriction::Queue

pub struct Queue {}

Zero sized marker struct for first-in-first-out read/write Semantics

This type typically only comes up in advanced use cases that are generic over read/write semantics. If you are looking for an entropy coder that operates as a queue, check out the module stream::queue.

Trait Implementations

impl<Word: Clone, Buf: AsRef<[Word]>> BoundedReadWords<Word, Queue> for Cursor<Word, Buf>

fn remaining(&self) -> usize

Returns the number of Words that are left for reading.

fn is_exhausted(&self) -> bool

Whether or not there is no data left to read.

impl<Word, B: BoundedReadWords<Word, Stack>> BoundedReadWords<Word, Queue> for Reverse<B>

fn remaining(&self) -> usize

Returns the number of Words that are left for reading.

fn is_exhausted(&self) -> bool

Whether or not there is no data left to read.

impl Debug for Queue

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

Formats the value using the given formatter.

impl Default for Queue

fn default() -> Queue

Returns the “default value” for a type.

impl<Word: BitArray, B: ReadWords<Word, Queue>> ReadBitStream<Queue> for QueueDecoder<Word, B>

type ReadError = <B as ReadWords<Word, Queue>>::ReadError

fn decode_symbol<C: DecoderCodebook>( &mut self, codebook: C ) -> Result<C::Symbol, CoderError<SymbolCodeError<C::InvalidCodeword>, Self::ReadError>>

fn read_bit(&mut self) -> Result<Option<bool>, Self::ReadError>

fn decode_symbols<'s, I, C>( &'s mut self, codebooks: I ) -> DecodeSymbols<'s, Self, I, S>

where I: IntoIterator<Item = C> + 's, C: DecoderCodebook,

fn decode_iid_symbols<'a, C>( &'a mut self, amt: usize, codebook: &'a C ) -> DecodeSymbols<'a, Self, Take<Repeat<&'a C>>, S>

where C: DecoderCodebook,

impl<Word: Clone, Buf: AsRef<[Word]>> ReadWords<Word, Queue> for Cursor<Word, Buf>

type ReadError = Infallible

The error type that can occur when reading from the data source, or Infallible.

fn read(&mut self) -> Result<Option<Word>, Self::ReadError>

Reads a single Word from the data source and advances the state of the data source accordingly (i.e., so that the next read won’t read the same Word again).

fn maybe_exhausted(&self) -> bool

Returns true if the data source could be out of data.

impl<Word, B: ReadWords<Word, Stack>> ReadWords<Word, Queue> for Reverse<B>

type ReadError = <B as ReadWords<Word, Stack>>::ReadError

The error type that can occur when reading from the data source, or Infallible.

fn read(&mut self) -> Result<Option<Word>, Self::ReadError>

Reads a single Word from the data source and advances the state of the data source accordingly (i.e., so that the next read won’t read the same Word again).

fn maybe_exhausted(&self) -> bool

Returns true if the data source could be out of data.

impl<Word: BitArray, B: WriteWords<Word>> WriteBitStream<Queue> for QueueEncoder<Word, B>

type WriteError = <B as WriteWords<Word>>::WriteError

fn write_bit(&mut self, bit: bool) -> Result<(), Self::WriteError>

fn encode_symbol<Symbol, C>( &mut self, symbol: Symbol, codebook: C ) -> Result<(), CoderError<DefaultEncoderFrontendError, Self::WriteError>>

where C: EncoderCodebook, Symbol: Borrow<C::Symbol>,

fn encode_symbols<Symbol, C>( &mut self, symbols_and_codebooks: impl IntoIterator<Item = (Symbol, C)> ) -> Result<(), CoderError<DefaultEncoderFrontendError, Self::WriteError>>

where C: EncoderCodebook, Symbol: Borrow<C::Symbol>,

fn encode_iid_symbols<Symbol, C>( &mut self, symbols: impl IntoIterator<Item = Symbol>, codebook: &C ) -> Result<(), CoderError<DefaultEncoderFrontendError, Self::WriteError>>

where C: EncoderCodebook, Symbol: Borrow<C::Symbol>,

impl Semantics for Queue