Struct ioat::AssertThreadSafe

pub struct AssertThreadSafe<T>(pub T);

A struct for wrapping thread-safe readers or writers.

Using this struct asserts, that the contained Read + Seek or Write + Seek value can be used for ReadAt and WriteAt, without risking a seek from another thread in parallel.

The traits are implemented by first seeking to the offset, and then calling the appropriate method on the wrapped value.

Trait Implementations

impl<T: Clone> Clone for AssertThreadSafe<T>

fn clone(&self) -> AssertThreadSafe<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for AssertThreadSafe<T>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T> ReadAt for AssertThreadSafe<T> where
    T: Read + Seek, 

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

Reads some bytes from pos bytes into the source.

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

Reads exactly buf.len() bytes from pos bytes into the source.

impl<T> WriteAt for AssertThreadSafe<T> where
    T: Write + Seek, 

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

Writes some bytes at pos bytes into self.

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

Flushes any pending writes to the underlying sink.

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

Writes exactly buf.len() bytes at pos bytes into self.