Struct ReadChunkSource 

pub struct ReadChunkSource<R, B = Vec<u8>> { /* private fields */ }

👎Deprecated since 0.3.1: This sync-only struct is superseded by the runtime-agnostic unescape_stream_into! macro.

A ChunkSource that reads from any std::io::Read type.

This struct manages an internal buffer, which is filled with data on each read operation. You can configure the buffer size to balance memory usage and I/O performance.

Implementations

impl<R, B> ReadChunkSource<R, B>

pub fn new(reader: R, buffer: B) -> Self

Creates a new ReadChunkSource with the given reader and a pre-allocated buffer.

The size of the chunks read will be determined by the buffer’s capacity.

pub fn with_buffer_size(reader: R, size: usize) -> ReadChunkSource<R, Vec<u8>>

Creates a new ReadChunkSource with the specified buffer size.

This is a convenience method that creates a new Vec<u8> with the given length (not just capacity) to use as the internal buffer.

Trait Implementations

impl<R, B> ChunkSource for ReadChunkSource<R, B>

where R: Read, B: AsMut<[u8]>,

type Error = Error

👎Deprecated since 0.3.1: This sync-only trait is superseded by the runtime-agnostic unescape_stream_into! macro.

The type of error that can occur when reading a chunk.

type Chunk<'a> = &'a [u8] where Self: 'a

👎Deprecated since 0.3.1: This sync-only trait is superseded by the runtime-agnostic unescape_stream_into! macro.

The type of chunk returned, which must implement AsRef<u8>

fn next_chunk<'a>(&'a mut self) -> Option<Result<Self::Chunk<'a>, Self::Error>>

👎Deprecated since 0.3.1: This sync-only trait is superseded by the runtime-agnostic unescape_stream_into! macro.

Get the next chunk of bytes.