Struct DecoderReader 

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

Async reader that streams Base64 input as decoded bytes.

This adapter decodes strict Base64 quanta as they arrive and preserves at most three pending encoded bytes between polls. If malformed input is observed, the adapter fails closed and clears its internal buffers.

Security

Streaming decode is not atomic. Decoded bytes from valid leading quanta may already have been returned before a later malformed quantum is observed. For atomic secret-bearing frames, use decode_reader_to_writer_limited or a ct staged decode after collecting a bounded frame.

Implementations

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

where A: Alphabet,

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

Creates a new async Base64 decoder reader.

pub const fn is_failed(&self) -> bool

Returns whether the adapter has encountered an unrecoverable error.

Trait Implementations

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

where R: AsyncRead + Unpin, A: Alphabet + Unpin,

fn poll_read( self: Pin<&mut Self>, context: &mut Context<'_>, destination: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

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

where A: Alphabet,

fn drop(&mut self)

Executes the destructor for this type.

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.