Struct Interposer 

pub struct Interposer<'a, S, D>
where
    S: Storage + ?Sized,
    D: Skip<Error = Infallible> + ?Sized,
{ /* private fields */ }

A wrapper around an underlying buffer (duplex) which will prefer to read/write from a user-provided temporary buffer (storage). The underlying buffer (duplex)’s current position and total length are updated if needed.

Implementations

impl<'a, S, D> Interposer<'a, S, D>

where S: Storage + ?Sized, D: Skip<Error = Infallible> + ?Sized,

pub fn new(storage: &'a mut S, duplex: &'a mut D) -> Self

Trait Implementations

impl<C, D> Reader for Interposer<'_, C, D>

where C: Storage + ?Sized, D: Skip<Error = Infallible> + ?Sized,

Delegates to the inner Duplex

fn current_offset(&self) -> VarInt

Returns the currently read offset for the stream

fn final_offset(&self) -> Option<VarInt>

Returns the final offset for the stream

fn has_buffered_fin(&self) -> bool

Returns true if the reader has the final offset buffered

fn is_consumed(&self) -> bool

Returns true if the reader is finished producing data

fn skip_until(&mut self, offset: VarInt) -> Result<(), Self::Error>

Skips the data in the reader until offset is reached, or the reader storage is exhausted.

fn with_max_data(&mut self, max_data: VarInt) -> Limit<'_, Self>

Limits the maximum offset that the caller can read from the reader

fn with_read_limit(&mut self, max_buffered_len: usize) -> Limit<'_, Self>

Limits the maximum amount of data that the caller can read from the reader

fn with_empty_buffer(&self) -> Empty<'_, Self>

Return an empty view onto the reader, with no change in current offset

fn with_checks(&mut self) -> Checked<'_, Self>

Enables checking the reader for correctness invariants

impl<S, D> Storage for Interposer<'_, S, D>

where S: Storage + ?Sized, D: Skip<Error = Infallible> + ?Sized,

Delegates to the inner Duplex

type Error = <D as Storage>::Error

fn buffered_len(&self) -> usize

Returns the length of the chunk

fn buffer_is_empty(&self) -> bool

Returns if the chunk is empty

fn read_chunk(&mut self, watermark: usize) -> Result<Chunk<'_>, Self::Error>

Reads the current contiguous chunk

fn partial_copy_into<Dest>( &mut self, dest: &mut Dest, ) -> Result<Chunk<'_>, Self::Error>

where Dest: Storage + ?Sized,

Copies the reader into dest, with a trailing chunk of bytes.

fn copy_into<Dest>(&mut self, dest: &mut Dest) -> Result<(), Self::Error>

where Dest: Storage + ?Sized,

Copies the reader into dest.

fn full_copy(&mut self) -> FullCopy<'_, Self>

Forces the entire reader to be copied, even when calling partial_copy_into.

fn track_read(&mut self) -> Tracked<'_, Self>

Tracks the number of bytes read from the storage

impl<C, D> Writer for Interposer<'_, C, D>

where C: Storage + ?Sized, D: Skip<Error = Infallible> + ?Sized,

fn read_from<R>(&mut self, reader: &mut R) -> Result<(), Error<R::Error>>

where R: Reader + ?Sized,