Struct Complete 

pub struct Complete<'a, S> { /* private fields */ }

Wraps a single Storage instance as a Reader.

This can be used for scenarios where the entire stream is buffered and known up-front.

Implementations

impl<'a, S> Complete<'a, S>

where S: Storage,

pub fn new(storage: &'a mut S) -> Result<Self, Error>

Trait Implementations

impl<'a, S: Debug> Debug for Complete<'a, S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C> Reader for Complete<'_, C>

where C: Storage,

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> Storage for Complete<'_, S>

where S: Storage,

type Error = <S 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