Skip to main content

DecoderReader

Struct DecoderReader 

Source
pub struct DecoderReader<R, A, const PAD: bool>
where A: Alphabet,
{ /* private fields */ }
Expand description

A streaming Base64 decoder for std::io::Read.

For padded engines, this reader stops at the terminal padded Base64 block and leaves later bytes unread in the wrapped reader. This preserves boundaries for callers that decode one Base64 payload from a larger stream.

Implementations§

Source§

impl<R, A, const PAD: bool> DecoderReader<R, A, PAD>
where A: Alphabet,

Source

pub fn new(inner: R, engine: Engine<A, PAD>) -> Self

Creates a new streaming decoder reader.

Source

pub fn get_ref(&self) -> &R

Returns a shared reference to the wrapped reader.

Source

pub fn get_mut(&mut self) -> &mut R

Returns a mutable reference to the wrapped reader.

Source

pub const fn engine(&self) -> Engine<A, PAD>

Returns the Base64 engine used by this adapter.

Source

pub const fn is_padded(&self) -> bool

Returns whether this adapter uses padded Base64.

Source

pub const fn pending_len(&self) -> usize

Returns the number of encoded input bytes currently buffered until a complete 4-byte Base64 decode quantum is available.

Source

pub const fn has_pending_input(&self) -> bool

Returns whether this decoder reader currently holds a partial input quantum.

Source

pub const fn pending_input_needed_len(&self) -> usize

Returns how many additional encoded input bytes are needed to complete the currently buffered decode quantum.

Returns 0 when no partial input quantum is buffered.

Source

pub const fn buffered_output_len(&self) -> usize

Returns the number of decoded bytes currently buffered and ready to be read before this adapter polls the wrapped reader again.

Source

pub const fn buffered_output_capacity(&self) -> usize

Returns the maximum number of decoded bytes this adapter can buffer before returning bytes to the caller.

Source

pub const fn buffered_output_remaining_capacity(&self) -> usize

Returns how many more decoded bytes can be buffered before this adapter must return bytes to the caller.

Source

pub const fn has_buffered_output(&self) -> bool

Returns whether this decoder reader currently has decoded output waiting in its internal queue.

Source

pub const fn has_terminal_padding(&self) -> bool

Returns whether this decoder reader has seen terminal padding.

For padded engines, this becomes true after the terminal padded block is decoded. The wrapped reader is then left positioned after that Base64 block so adjacent framed bytes can be read by the caller.

Source

pub const fn has_finished_input(&self) -> bool

Returns whether this decoder reader has reached EOF or terminal padding in the wrapped reader.

This may become true before Self::is_finished when decoded output is still buffered for the caller.

Source

pub const fn is_finished(&self) -> bool

Returns whether this reader has reached EOF or terminal padding and has no decoded output buffered for the caller.

Source

pub const fn is_failed(&self) -> bool

Returns whether this decoder reader has rejected malformed Base64 input.

Once this returns true, later reads return an error. The unchecked Self::into_inner method can still be used for explicit recovery of the wrapped reader.

Source

pub const fn can_into_inner(&self) -> bool

Returns whether Self::try_into_inner can recover the wrapped reader without discarding buffered decoded output.

Source

pub fn into_inner(self) -> R

Consumes the decoder reader and returns the wrapped reader.

Source

pub fn try_into_inner(self) -> Result<R, Self>

Consumes the decoder reader only after the Base64 payload is fully drained.

For padded streams, terminal padding may leave adjacent framed bytes unread in the wrapped reader. This method succeeds only after all decoded output buffered by this adapter has been read, so recovering the wrapped reader does not silently discard decoded bytes.

Trait Implementations§

Source§

impl<R, A, const PAD: bool> Debug for DecoderReader<R, A, PAD>
where A: Alphabet,

Source§

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

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

impl<R, A, const PAD: bool> Drop for DecoderReader<R, A, PAD>
where A: Alphabet,

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more
Source§

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)
Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned. Read more
Source§

impl<R, A, const PAD: bool> Read for DecoderReader<R, A, PAD>
where R: Read, A: Alphabet,

Source§

fn read(&mut self, output: &mut [u8]) -> Result<usize>

Pull some bytes from this source into the specified buffer, returning how many bytes were read. Read more
1.36.0 · Source§

fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize, Error>

Like read, except that it reads into a slice of buffers. Read more
Source§

fn is_read_vectored(&self) -> bool

🔬This is a nightly-only experimental API. (can_vector)
Determines if this Reader has an efficient read_vectored implementation. Read more
1.0.0 · Source§

fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize, Error>

Reads all bytes until EOF in this source, placing them into buf. Read more
1.0.0 · Source§

fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>

Reads all bytes until EOF in this source, appending them to buf. Read more
1.6.0 · Source§

fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>

Reads the exact number of bytes required to fill buf. Read more
Source§

fn read_buf(&mut self, buf: BorrowedCursor<'_>) -> Result<(), Error>

🔬This is a nightly-only experimental API. (read_buf)
Pull some bytes from this source into the specified buffer. Read more
Source§

fn read_buf_exact(&mut self, cursor: BorrowedCursor<'_>) -> Result<(), Error>

🔬This is a nightly-only experimental API. (read_buf)
Reads the exact number of bytes required to fill cursor. Read more
1.0.0 · Source§

fn by_ref(&mut self) -> &mut Self
where Self: Sized,

Creates a “by reference” adapter for this instance of Read. Read more
1.0.0 · Source§

fn bytes(self) -> Bytes<Self>
where Self: Sized,

Transforms this Read instance to an Iterator over its bytes. Read more
1.0.0 · Source§

fn chain<R>(self, next: R) -> Chain<Self, R>
where R: Read, Self: Sized,

Creates an adapter which will chain this stream with another. Read more
1.0.0 · Source§

fn take(self, limit: u64) -> Take<Self>
where Self: Sized,

Creates an adapter which will read at most limit bytes from it. Read more
Source§

fn read_array<const N: usize>(&mut self) -> Result<[u8; N], Error>
where Self: Sized,

🔬This is a nightly-only experimental API. (read_array)
Read and return a fixed array of bytes from this source. Read more

Auto Trait Implementations§

§

impl<R, A, const PAD: bool> Freeze for DecoderReader<R, A, PAD>
where R: Freeze,

§

impl<R, A, const PAD: bool> RefUnwindSafe for DecoderReader<R, A, PAD>

§

impl<R, A, const PAD: bool> Send for DecoderReader<R, A, PAD>
where R: Send, A: Send,

§

impl<R, A, const PAD: bool> Sync for DecoderReader<R, A, PAD>
where R: Sync, A: Sync,

§

impl<R, A, const PAD: bool> Unpin for DecoderReader<R, A, PAD>
where R: Unpin, A: Unpin,

§

impl<R, A, const PAD: bool> UnsafeUnpin for DecoderReader<R, A, PAD>
where R: UnsafeUnpin,

§

impl<R, A, const PAD: bool> UnwindSafe for DecoderReader<R, A, PAD>
where R: UnwindSafe, A: 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 = Infallible

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

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

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.