Struct OpenedAsyncDirectoryStream 

pub struct OpenedAsyncDirectoryStream { /* private fields */ }

An already-open asynchronous directory stream.

Examples

use qubit_fs::error::FsResult;
use qubit_fs::metadata::DirEntry;
use qubit_fs::spi::{AsyncDirectoryStreamSession, OpenedAsyncDirectoryStream, SpiFuture};

struct EmptyStream;
impl AsyncDirectoryStreamSession for EmptyStream {
    fn next_entry_async(&mut self) -> SpiFuture<'_, FsResult<Option<DirEntry>>> {
        Box::pin(async { Ok(None) })
    }
}
let _stream = OpenedAsyncDirectoryStream::new(Box::new(EmptyStream));

Implementations

impl OpenedAsyncDirectoryStream

pub fn new(session: Box<dyn AsyncDirectoryStreamSession>) -> Self

Wraps an opened provider directory-enumeration session.

Parameters

• session: Provider enumeration session.

Returns

An opened asynchronous stream envelope for facade validation.