Struct block_device_adapters::StreamSlice

pub struct StreamSlice<T: Read + Write + Seek> { /* private fields */ }

Stream wrapper for accessing limited segment of data from underlying file or device.

Implementations

impl<T: Read + Write + Seek> StreamSlice<T>

pub async fn new( inner: T, start_offset: u64, end_offset: u64 ) -> Result<Self, StreamSliceError<T::Error>>

Creates new StreamSlice from inner stream and offset range.

start_offset is inclusive offset of the first accessible byte. end_offset is exclusive offset of the first non-accessible byte. start_offset must be lower or equal to end_offset.

pub fn into_inner(self) -> T

Returns inner object

Trait Implementations

impl<T: Read + Write + Seek> ErrorType for StreamSlice<T>

type Error = StreamSliceError<<T as ErrorType>::Error>

Error type of all the IO operations on this type.

impl<T: Read + Write + Seek> Read for StreamSlice<T>

async fn read( &mut self, buf: &mut [u8] ) -> Result<usize, StreamSliceError<T::Error>>

Read some bytes from this source into the specified buffer, returning how many bytes were read.

async fn read_exact( &mut self, buf: &mut [u8] ) -> Result<(), ReadExactError<Self::Error>>

Read the exact number of bytes required to fill buf.

impl<T: Read + Write + Seek> Seek for StreamSlice<T>

async fn seek( &mut self, pos: SeekFrom ) -> Result<u64, StreamSliceError<T::Error>>

Seek to an offset, in bytes, in a stream.

async fn rewind(&mut self) -> Result<(), Self::Error>

Rewind to the beginning of a stream.

async fn stream_position(&mut self) -> Result<u64, Self::Error>

Returns the current seek position from the start of the stream.

impl<T: Read + Write + Seek> Write for StreamSlice<T>

async fn write( &mut self, buf: &[u8] ) -> Result<usize, StreamSliceError<T::Error>>

Write a buffer into this writer, returning how many bytes were written.

async fn flush(&mut self) -> Result<(), StreamSliceError<T::Error>>

Flush this output stream, ensuring that all intermediately buffered contents reach their destination.

async fn write_all(&mut self, buf: &[u8]) -> Result<(), Self::Error>

Write an entire buffer into this writer.