Trait ReadExt 

pub trait ReadExt: Read {
    // Required methods
    fn read_exact_or_eof(&mut self, buffer: &mut [u8]) -> Result<usize>;
    fn read_exact_array<const N: usize>(&mut self) -> Result<[u8; N]>;
    fn read_exact_vec_limited(
        &mut self,
        len: usize,
        max_len: usize,
    ) -> Result<Vec<u8>>;
    fn read_exact_vec_limited_into(
        &mut self,
        output: &mut Vec<u8>,
        len: usize,
        max_len: usize,
    ) -> Result<()>;
    fn discard_exact_or_eof(&mut self, bytes: u64) -> Result<u64>;
    fn copy_to(&mut self, writer: &mut dyn Write) -> Result<u64>;
    fn copy_to_at_most(
        &mut self,
        writer: &mut dyn Write,
        max_bytes: u64,
    ) -> Result<u64>;
    fn copy_to_end_limited(
        &mut self,
        writer: &mut dyn Write,
        max_bytes: u64,
    ) -> Result<u64>;
    fn read_to_end_limited(&mut self, max_len: usize) -> Result<Vec<u8>>;
    fn read_to_end_limited_into(
        &mut self,
        output: &mut Vec<u8>,
        max_len: usize,
    ) -> Result<usize>;
    fn read_to_string_limited(&mut self, max_len: usize) -> Result<String>;
    fn read_to_string_limited_into(
        &mut self,
        output: &mut String,
        max_len: usize,
    ) -> Result<usize>;
}

Extension methods for Read values.

ReadExt fills small semantic gaps in the standard Read trait while keeping the same blocking and error model. The methods are implemented for every type that implements Read, including dyn Read trait objects.

Examples

use qubit_io::ReadExt;
use std::io::Cursor;

let mut input = Cursor::new(b"abcdef".to_vec());
let header = input.read_exact_array::<2>()?;
let payload = input.read_exact_vec_limited(4, 16)?;

assert_eq!(*b"ab", header);
assert_eq!(b"cdef", payload.as_slice());

Required Methods

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

Reads bytes until buffer is full or EOF is reached.

This method differs from Read::read_exact by treating EOF as a successful partial result. It keeps retrying short reads until the caller-provided buffer is full, EOF is reached, or a non-interrupted I/O error occurs.

Parameters

• buffer: Destination buffer to fill.

Returns

The number of bytes written into buffer. The value is in 0..=buffer.len().

Errors

Returns the first non-ErrorKind::Interrupted error reported by the underlying reader. Interrupted reads are retried.

fn read_exact_array<const N: usize>(&mut self) -> Result<[u8; N]>

Reads exactly N bytes into a stack-allocated array.

This method uses Read::read_exact and therefore requires the reader to provide exactly N bytes before EOF.

Returns

An array containing exactly N bytes read from this reader.

Errors

Returns the error reported by Read::read_exact, including ErrorKind::UnexpectedEof when EOF is reached before the array is full.

fn read_exact_vec_limited( &mut self, len: usize, max_len: usize, ) -> Result<Vec<u8>>

Reads exactly len bytes into a new vector after checking a limit.

If len is greater than max_len, this method returns ErrorKind::InvalidData before reading any bytes.

Parameters

• len: Exact number of bytes to read.
• max_len: Maximum accepted exact read length.

Returns

A vector containing exactly len bytes.

Errors

Returns ErrorKind::InvalidData when len > max_len. Returns the error reported by Read::read_exact, including ErrorKind::UnexpectedEof when EOF is reached before len bytes are read.

fn read_exact_vec_limited_into( &mut self, output: &mut Vec<u8>, len: usize, max_len: usize, ) -> Result<()>

Reads exactly len bytes and appends them to output.

If len is greater than max_len, this method returns ErrorKind::InvalidData before reading any bytes and leaves output unchanged. On a read error, output is truncated back to its original length. The underlying reader may still have consumed bytes before the error because Read does not provide rollback.

Parameters

• output: Destination vector to append to.
• len: Exact number of bytes to read.
• max_len: Maximum accepted exact read length.

Errors

Returns ErrorKind::InvalidData when len > max_len. Returns the error reported by Read::read_exact, including ErrorKind::UnexpectedEof when EOF is reached before len bytes are read.

fn discard_exact_or_eof(&mut self, bytes: u64) -> Result<u64>

Discards up to bytes bytes from this reader.

The method repeatedly reads into an internal stack buffer until the requested number of bytes has been consumed or EOF is reached. It does not allocate and does not require seeking support.

Parameters

• bytes: Maximum number of bytes to discard.

Returns

The number of bytes actually discarded. The value may be smaller than bytes when EOF is reached first.

Errors

Returns the first non-ErrorKind::Interrupted error reported by the underlying reader. Interrupted reads are retried.

fn copy_to(&mut self, writer: &mut dyn Write) -> Result<u64>

Copies all remaining bytes from this reader into writer.

This method is a method-style wrapper around std::io::copy. It copies from the current reader position until EOF and does not close or flush either stream.

Parameters

• writer: Destination writer.

Returns

The number of bytes copied.

Errors

Returns the first read or write error reported by the underlying streams, using the same error behavior as std::io::copy.

fn copy_to_at_most( &mut self, writer: &mut dyn Write, max_bytes: u64, ) -> Result<u64>

Copies at most max_bytes bytes from this reader into writer.

This method stops successfully when either EOF is reached or max_bytes bytes have been copied. It does not close or flush either stream.

Parameters

• writer: Destination writer.
• max_bytes: Maximum number of bytes to copy.

Returns

The number of bytes copied.

Errors

Returns the first non-ErrorKind::Interrupted read error or write error reported by the underlying streams. Interrupted reads are retried.

fn copy_to_end_limited( &mut self, writer: &mut dyn Write, max_bytes: u64, ) -> Result<u64>

Copies the remaining input if its total length is at most max_bytes.

This method copies from the current reader position until EOF. If EOF is not reached within max_bytes bytes, it returns ErrorKind::InvalidData. Detecting oversized input consumes one excess byte from this reader; that excess byte is not written to writer.

Parameters

• writer: Destination writer.
• max_bytes: Maximum accepted number of bytes in the remaining input.

Returns

The number of bytes copied when EOF is reached within the limit.

Errors

Returns ErrorKind::InvalidData when the remaining input is longer than max_bytes. Returns the first non-ErrorKind::Interrupted read error or write error reported by the underlying streams. Interrupted reads are retried.

fn read_to_end_limited(&mut self, max_len: usize) -> Result<Vec<u8>>

Reads the remaining bytes into a vector with a maximum accepted length.

This method consumes bytes from the current reader position until EOF is reached. If the stream contains more than max_len bytes, it returns ErrorKind::InvalidData after detecting the first excess byte.

Parameters

• max_len: Maximum number of bytes accepted in the returned vector.

Returns

A vector containing all remaining bytes when the stream length is within the limit.

Errors

Returns ErrorKind::InvalidData when the stream contains more than max_len bytes. Returns the first non-ErrorKind::Interrupted error reported by the underlying reader; interrupted reads are retried.

fn read_to_end_limited_into( &mut self, output: &mut Vec<u8>, max_len: usize, ) -> Result<usize>

Reads the remaining bytes into output with a maximum accepted length.

This method appends at most max_len bytes from the current reader position to output. If the stream contains more than max_len bytes, it returns ErrorKind::InvalidData after detecting the first excess byte. In that case, the accepted prefix may already have been appended to output, and one excess byte may have been consumed from the reader.

Parameters

• output: Destination vector to append to.
• max_len: Maximum number of bytes accepted from this reader.

Returns

The number of bytes appended to output.

Errors

Returns ErrorKind::InvalidData when the stream contains more than max_len bytes. Returns the first non-ErrorKind::Interrupted error reported by the underlying reader; interrupted reads are retried.

fn read_to_string_limited(&mut self, max_len: usize) -> Result<String>

Reads the remaining bytes as UTF-8 text with a maximum accepted length.

This method has the same size limit and read semantics as ReadExt::read_to_end_limited, then validates the collected bytes as UTF-8.

Parameters

• max_len: Maximum number of bytes accepted before UTF-8 decoding.

Returns

The decoded UTF-8 string.

Errors

Returns ErrorKind::InvalidData when the stream contains more than max_len bytes or when the collected bytes are not valid UTF-8. Returns the first non-ErrorKind::Interrupted error reported by the underlying reader; interrupted reads are retried.

fn read_to_string_limited_into( &mut self, output: &mut String, max_len: usize, ) -> Result<usize>

Reads the remaining bytes as UTF-8 text and appends to output.

This method accepts at most max_len bytes from the current reader position, validates them as UTF-8, and appends the decoded text to output. If the input is oversized or invalid UTF-8, output is left unchanged. Oversized input may still consume up to max_len + 1 bytes from the reader while detecting the limit violation.

Parameters

• output: Destination string to append to.
• max_len: Maximum number of bytes accepted before UTF-8 decoding.

Returns

The number of bytes appended to output.

Errors

Returns ErrorKind::InvalidData when the stream contains more than max_len bytes or when the collected bytes are not valid UTF-8. Returns the first non-ErrorKind::Interrupted error reported by the underlying reader; interrupted reads are retried.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<T> ReadExt for T

where T: Read + ?Sized,