Struct btlib::crypto::merkle_stream::MerkleStream

pub struct MerkleStream<T> { /* private fields */ }

Implementations

impl<T: MetaReader> MerkleStream<T>

pub fn assert_root_integrity(&mut self) -> Result<()>

Asserts that the root merkle node contains the integrity value given by the inner stream.

impl<T: ReadAt + Size + Sectored> MerkleStream<T>

pub fn new(inner: T) -> Result<MerkleStream<T>>

Reads a MerkleTree from the end of the given stream and returns a stream which uses it.

pub fn with_tree(inner: T, tree: VariantMerkleTree) -> Result<MerkleStream<T>>

Trait Implementations

impl<U, T: AsMut<U>> AsMut<U> for MerkleStream<T>

fn as_mut(&mut self) -> &mut U

Converts this type into a mutable reference of the (usually inferred) input type.

impl<U, T: AsRef<U>> AsRef<U> for MerkleStream<T>

fn as_ref(&self) -> &U

Converts this type into a shared reference of the (usually inferred) input type.

impl<T> Decompose<T> for MerkleStream<T>

fn into_inner(self) -> T

impl<T: FlushMeta> FlushMeta for MerkleStream<T>

fn flush_meta(&mut self) -> Result<()>

Flushes metadata to persistent storage.

impl<T: ReadAt + Size> ReadAt for MerkleStream<T>

fn read_at(&self, pos: u64, buf: &mut [u8]) -> Result<usize>

Reads bytes from an offset in this source into a buffer, returning how many bytes were read.

fn read_exact_at(&self, pos: u64, buf: &mut [u8]) -> Result<(), Error>

Reads the exact number of bytes required to fill buf from an offset.

impl<T> Sectored for MerkleStream<T>

fn sector_sz(&self) -> usize

Returns the size of the sector for this stream.

fn sector_sz64(&self) -> u64

Returns the sector size as a u64.

fn assert_sector_sz(&self, actual: usize) -> Result<()>

Returns Err(Error::IncorrectSize) if the given size is not equal to the sector size.

fn assert_at_least_sector_sz(&self, actual: usize) -> Result<()>

Returns Err(Error::IncorrectSize) if the given size is less than the sector size.

fn offset_at(&self, index: u64) -> u64

Returns the offset (in bytes) from the beginning of this stream that the given 0-based sector index corresponds to.

impl<T> Size for MerkleStream<T>

fn size(&self) -> Result<Option<u64>>

Get the size of this object, in bytes.

impl<T: WriteInteg + Size> WriteAt for MerkleStream<T>

fn write_at(&mut self, pos: u64, buf: &[u8]) -> Result<usize>

Writes bytes from a buffer to an offset, returning the number of bytes written.

fn flush(&mut self) -> Result<()>

Flush this writer, ensuring that any intermediately buffered data reaches its destination.

fn write_all_at(&mut self, pos: u64, buf: &[u8]) -> Result<(), Error>

Writes a complete buffer at an offset.