ReadChunkSource

Struct ReadChunkSource 

Source
pub struct ReadChunkSource<R, B> { /* private fields */ }
Expand description

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§

Source§

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

Source

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.

Source

pub fn with_capacity(reader: R, capacity: usize) -> ReadChunkSource<R, Vec<u8>>

Creates a new ReadChunkSource with the specified buffer capacity.

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

Trait Implementations§

Source§

impl<R, B> ChunkSource for ReadChunkSource<R, B>
where R: Read, B: AsMut<[u8]>,

Source§

type Error = Error

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

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

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

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

Get the next chunk of bytes. Read more

Auto Trait Implementations§

§

impl<R, B> Freeze for ReadChunkSource<R, B>
where R: Freeze, B: Freeze,

§

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

§

impl<R, B> Send for ReadChunkSource<R, B>
where R: Send, B: Send,

§

impl<R, B> Sync for ReadChunkSource<R, B>
where R: Sync, B: Sync,

§

impl<R, B> Unpin for ReadChunkSource<R, B>
where R: Unpin, B: Unpin,

§

impl<R, B> UnwindSafe for ReadChunkSource<R, B>
where R: UnwindSafe, B: 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.