Struct CachedSource 

pub struct CachedSource<S: ByteSource> { /* private fields */ }

Implementations

impl<S: ByteSource> CachedSource<S>

pub fn new(inner: S, block_size: u64, max_blocks: usize) -> Self

pub fn into_inner(self) -> S

pub fn block_size(&self) -> u64

pub fn cached_blocks(&self) -> usize

How many blocks are resident. Tests and benchmarks read this; nothing else should.

Trait Implementations

impl<S: ByteSource> ByteSource for CachedSource<S>

fn path(&self) -> &str

Path or URL this reads, for error messages.

fn len(&self) -> Result<u64>

Total length in bytes.

fn read_at(&self, offset: u64, len: usize) -> Result<Bytes>

Read up to len bytes at offset, returning fewer at end of file.

fn prefetch(&self, ranges: &[Range<u64>])

Announce ranges that are about to be read, so a source that can fetch them together does. A no-op unless overridden.

fn close(&self)

Release the underlying handle. Idempotent; reads after it fail with Error::Closed.

fn is_empty(&self) -> Result<bool>

fn read_exact_at(&self, offset: u64, len: usize) -> Result<Bytes>

Read exactly len bytes at offset; a short read is Error::Corrupt.

fn read_to_end(&self, offset: u64) -> Result<Bytes>

Read from offset to end of file.

impl<S: Debug + ByteSource> Debug for CachedSource<S>

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

Formats the value using the given formatter.