Struct AsyncFileReader 

pub struct AsyncFileReader { /* private fields */ }

Type-erased asynchronous byte input associated with an opened file.

Examples

This example uses an isolated in-memory provider fixture.

use qubit_fs::Path;
use qubit_fs::read::ReadOptions;
use qubit_io::AsyncInput;

let mut reader = filesystem.open_reader(&Path::parse("/report")?, ReadOptions::default()).await?;
let mut prefix = [0; 3];
assert_eq!(3, reader.read_fully_async(&mut prefix).await?);
assert_eq!(*b"byt", prefix);

Implementations

impl AsyncFileReader

pub fn info(&self) -> &OpenedFileInfo

Returns the fixed identity and open-time metadata snapshot.

Returns

Information captured when the reader was opened.

Trait Implementations

impl AsyncInput for AsyncFileReader

type Item = u8

The item type read from this input.

fn is_buffered(&self) -> bool

Returns whether this input already buffers items internally.

unsafe fn poll_read_unchecked( self: Pin<&mut Self>, cx: &mut Context<'_>, output: &mut [u8], index: usize, count: usize, ) -> Poll<IoResult<usize>>

Polls an indexed read without checking the destination range.

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

Polls a read into the full destination slice.

fn read_async<'a>( &'a mut self, output: &'a mut [Self::Item], ) -> ReadFuture<'a, Self>

where Self: Sized + Unpin,

Creates a future that performs one asynchronous read operation.

fn read_fully_async<'a>( &'a mut self, output: &'a mut [Self::Item], ) -> ReadFullyFuture<'a, Self>

where Self: Sized + Unpin,

Creates a future that fills a destination as far as possible.

fn read_exactly_async<'a>( &'a mut self, output: &'a mut [Self::Item], ) -> ReadExactFuture<'a, Self>

where Self: Sized + Unpin,

Creates a future that fills the entire destination.

impl Debug for AsyncFileReader

fn fmt(&self, formatter: &mut Formatter<'_>) -> FmtResult

Formats the value using the given formatter.