Skip to main content

CodecTranscodeDecoder

Struct CodecTranscodeDecoder 

Source
pub struct CodecTranscodeDecoder<C> { /* private fields */ }
Expand description

Decodes encoded units into caller-provided value buffers by using a Codec.

CodecTranscodeDecoder is a policy-free bridge from the low-level unchecked Codec contract to Transcoder and TranscodeDecoder. It leaves incomplete input tails in the caller-provided input slice while the stream remains open. Call Transcoder::transcode_eof after upstream EOF so codecs can apply their Codec::decode_eof policy to a trailing prefix.

§Type Parameters

  • C: Low-level codec used to decode values.

§Examples

use qubit_codec::{Codec, CodecTranscodeDecoder};

fn make_decoder<C: Codec>(codec: C) -> CodecTranscodeDecoder<C> {
    CodecTranscodeDecoder::new(codec)
}

Implementations§

Source§

impl<C> CodecTranscodeDecoder<C>
where C: Codec,

Source

pub fn new(codec: C) -> Self

Creates a buffered decoder backed by codec.

§Parameters
  • codec: Low-level codec used to decode values.
§Returns

Returns a buffered decoder adapter for the supplied codec.

Source

pub fn codec(&self) -> &C

Returns a shared reference to the wrapped codec.

Source

pub fn codec_mut(&mut self) -> &mut C

Returns a mutable reference to the wrapped codec.

Mutating a codec during an active stream can invalidate that stream’s assumptions; reset the adapter before continuing with the new codec configuration.

Source

pub fn into_codec(self) -> C

Consumes the adapter and returns its wrapped codec.

Any buffered lifecycle state and internal hooks are discarded.

Trait Implementations§

Source§

impl<C: Debug> Debug for CodecTranscodeDecoder<C>

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<C: Default> Default for CodecTranscodeDecoder<C>

Source§

fn default() -> CodecTranscodeDecoder<C>

Returns the “default value” for a type. Read more
Source§

impl<C> TranscodeDecoder for CodecTranscodeDecoder<C>
where C: Codec,

Source§

type DecodeError = <C as Codec>::DecodeError

Domain error type produced by decode internals.
Source§

impl<C> Transcoder for CodecTranscodeDecoder<C>
where C: Codec,

Source§

fn max_transcode_output_len( &self, input_len: usize, ) -> Result<usize, CapacityError>

Returns an upper bound for decoded values produced from input_len units.

§Parameters
  • input_len: Source units the caller plans to decode.
§Returns

Returns a conservative upper bound for decoded values.

Source§

fn max_finish_output_len(&self) -> Result<usize, CapacityError>

Returns the global maximum values emitted by finishing internal state.

§Returns

Returns the number of values that may still be emitted by finishing state.

Source§

fn max_reset_output_len(&self) -> Result<usize, CapacityError>

Returns the global maximum values emitted when resetting internal state.

Source§

fn reset( &mut self, output: &mut [C::Value], output_index: usize, ) -> Result<usize, TranscodeDecodeErrorOf<C>>

Runs before-reset cleanup for decoder state.

Source§

fn transcode( &mut self, input: &[C::Unit], input_index: usize, output: &mut [C::Value], output_index: usize, ) -> Result<TranscodeProgress, TranscodeDecodeErrorOf<C>>

Decodes source units into logical values.

§Parameters
  • input: Source unit slice.
  • input_index: Absolute source index where decoding starts.
  • output: Destination value slice.
  • output_index: Absolute output value index where writing starts.
§Returns

Returns conversion progress for consumed and written counters.

§Errors

Returns a decode error when indices are invalid or when conversion fails under hook policy.

Source§

fn transcode_eof( &mut self, input: &[C::Unit], input_index: usize, output: &mut [C::Value], output_index: usize, ) -> Result<TranscodeProgress, TranscodeDecodeErrorOf<C>>

Transcodes an input segment while marking it as the end of the stream.

This forwarding implementation lets the engine apply EOF-specific decoder behavior before returning progress to the caller.

Source§

fn finish( &mut self, output: &mut [C::Value], output_index: usize, ) -> Result<usize, TranscodeDecodeErrorOf<C>>

Finishes internally retained output after EOF.

§Parameters
  • output: Destination value slice for final retained values.
  • output_index: Absolute output value index where writing starts.
§Returns

Returns the number of values written by finalization.

§Errors

Returns a finish error if finalization cannot complete.

Source§

type Input = <C as Codec>::Unit

Input unit type accepted by this transcoder.
Source§

type Output = <C as Codec>::Value

Output unit type produced by this transcoder.
Source§

type Error = TranscodeDecodeError<<C as Codec>::DecodeError>

Complete error type produced by this transcoder.
Source§

fn max_total_output_len(&self, input_len: usize) -> Result<usize, CapacityError>

Returns an upper bound for a complete reset -> transcode -> finish stream. Read more
Source§

fn transcode_complete_into( &mut self, input: &[Self::Input], output: &mut [Self::Output], ) -> Result<usize, Self::Error>

Runs a complete one-shot reset -> transcode -> finish stream. Read more

Auto Trait Implementations§

§

impl<C> Freeze for CodecTranscodeDecoder<C>
where TranscodeDecodeEngine<C, CodecTranscodeDecodeHooks>: Freeze,

§

impl<C> RefUnwindSafe for CodecTranscodeDecoder<C>
where TranscodeDecodeEngine<C, CodecTranscodeDecodeHooks>: RefUnwindSafe,

§

impl<C> Send for CodecTranscodeDecoder<C>
where TranscodeDecodeEngine<C, CodecTranscodeDecodeHooks>: Send,

§

impl<C> Sync for CodecTranscodeDecoder<C>
where TranscodeDecodeEngine<C, CodecTranscodeDecodeHooks>: Sync,

§

impl<C> Unpin for CodecTranscodeDecoder<C>
where TranscodeDecodeEngine<C, CodecTranscodeDecodeHooks>: Unpin,

§

impl<C> UnsafeUnpin for CodecTranscodeDecoder<C>
where TranscodeDecodeEngine<C, CodecTranscodeDecodeHooks>: UnsafeUnpin,

§

impl<C> UnwindSafe for CodecTranscodeDecoder<C>
where TranscodeDecodeEngine<C, CodecTranscodeDecodeHooks>: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.