Struct FileStream 

pub struct FileStream { /* private fields */ }

A stream over a tokio::fs::File that implements SeekableStream.

Implementations

impl FileStream

pub fn builder(file: File) -> FileStreamBuilder

Creates a new FileStreamBuilder.

Arguments

• handle - An open tokio::fs::File to stream.

Notes

len() is the file size returned from Metadata::len() regardless of the initial position of the File.

Trait Implementations

impl AsyncRead for FileStream

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

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

Formats the value using the given formatter.

impl From<FileStream> for Body

fn from(stream: FileStream) -> Self

Converts to this type from the input type.

impl SeekableStream for FileStream

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

Gets the length of the underlying File.

Notes

len() is the file size returned from Metadata::len() regardless of the initial position of the File.

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

where Self: 'async_trait, 'life0: 'async_trait,

Resets the stream position to the beginning.

fn buffer_size(&self) -> usize

Returns the size of the buffer to use when reading from the stream.

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

Returns true if the stream is empty, if known.