Struct FileStream 

pub struct FileStream {
    pub stream_size: u64,
    pub block_size: u64,
    pub offset: u64,
    /* private fields */
}

Fields

stream_size: u64

block_size: u64

offset: u64

Implementations

impl FileStream

pub async fn next_block(&mut self) -> Result<(), Error>

Resets the number of bytes that will be read from this instance to the stream_size

This is useful if you want to read the stream in multiple blocks

Trait Implementations

impl AsyncRead for FileStream

fn poll_read( self: Pin<&mut FileStream>, cx: &mut Context<'_>, slice: &mut [u8], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl Clone for FileStream

fn clone(&self) -> FileStream

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileStream

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

Formats the value using the given formatter.

impl From<&FileStream> for Body

fn from(stream: &FileStream) -> Body

Converts to this type from the input type.

impl From<FileStream> for Body

fn from(stream: FileStream) -> Body

Converts to this type from the input type.

impl SeekableStream for FileStream

fn reset<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileStream: 'async_trait,

Seek to the specified offset into the file and reset the number of bytes to read

This is useful upon encountering an error to reset the stream to the last

fn len(&self) -> usize

fn buffer_size(&self) -> usize

fn is_empty(&self) -> bool

impl<'pin> Unpin for FileStream

where <PinnedFieldsOfHelperStruct<__FileStream<'pin>> as PinnedFieldsOfHelperTrait>::Actual: Unpin,