Struct OpenedAsyncReader 

pub struct OpenedAsyncReader { /* private fields */ }

An already-open asynchronous reader bound to provider identity.

Examples

use qubit_fs::metadata::{FileKind, FileMetadata, FileSystemId, OpenedFileInfo};
use qubit_fs::path::Path;
use qubit_fs::spi::OpenedAsyncReader;

let info = OpenedFileInfo::new(FileSystemId::new("doc")?, Path::parse("/x")?)
    .with_metadata(FileMetadata::new(FileKind::File));
assert!(std::any::type_name::<OpenedAsyncReader>().contains("OpenedAsyncReader"));
assert_eq!("/x", info.path().as_str());

Implementations

impl OpenedAsyncReader

pub fn new( info: OpenedFileInfo, reader: Box<dyn AsyncInput<Item = u8> + Send>, ) -> Self

Wraps a provider-opened reader session and its claimed identity.

Parameters

• info: Identity claimed for the opened resource.
• reader: Provider asynchronous byte-input session.

Returns

An opened-reader envelope for facade validation.

pub fn info(&self) -> &OpenedFileInfo

Returns the immutable provider-opened identity.

Returns

The identity claimed by the provider.