Struct wasmtime_wasi::virtfs::pipe::ReadPipe

pub struct ReadPipe<R> where
    R: Read + Any,  { /* private fields */ }

A virtual pipe read end.

A variety of From impls are provided so that common pipe types are easy to create. For example:

let mut ctx = WasiCtxBuilder::new();
let stdin = ReadPipe::from("hello from stdin!");
ctx.stdin(stdin);

Implementations

impl<R> ReadPipe<R> where
    R: Read + Any, 

pub fn new(r: R) -> ReadPipe<R>

Create a new pipe from a Read type.

All Handle read operations delegate to reading from this underlying reader.

pub fn from_shared(reader: Arc<RwLock<R>>) -> ReadPipe<R>

Create a new pipe from a shareable Read type.

All Handle read operations delegate to reading from this underlying reader.

pub fn try_into_inner(self) -> Result<R, ReadPipe<R>>

Try to convert this ReadPipe<R> back to the underlying R type.

This will fail with Err(self) if multiple references to the underlying R exist.

Trait Implementations

impl<R> Clone for ReadPipe<R> where
    R: Read + Any, 

pub fn clone(&self) -> ReadPipe<R>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<R> Debug for ReadPipe<R> where
    R: Debug + Read + Any, 

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

Formats the value using the given formatter.

impl From<&'_ [u8]> for ReadPipe<Cursor<Vec<u8, Global>>>

pub fn from(r: &[u8]) -> ReadPipe<Cursor<Vec<u8, Global>>>

Performs the conversion.

impl From<&'_ str> for ReadPipe<Cursor<String>>

pub fn from(r: &str) -> ReadPipe<Cursor<String>>

Performs the conversion.

impl From<String> for ReadPipe<Cursor<String>>

pub fn from(r: String) -> ReadPipe<Cursor<String>>

Performs the conversion.

impl From<Vec<u8, Global>> for ReadPipe<Cursor<Vec<u8, Global>>>

pub fn from(r: Vec<u8, Global>) -> ReadPipe<Cursor<Vec<u8, Global>>>

Performs the conversion.

impl<R> Handle for ReadPipe<R> where
    R: Read + Any, 

pub fn as_any(&self) -> &(dyn Any + 'static)

pub fn try_clone(&self) -> Result<Box<dyn Handle + 'static, Global>, Error>

pub fn get_file_type(&self) -> Filetype

pub fn get_rights(&self) -> HandleRights

pub fn set_rights(&self, rights: HandleRights)

pub fn advise(
    &self,
    _advice: Advice,
    _offset: u64,
    _len: u64
) -> Result<(), Error>

pub fn allocate(&self, _offset: u64, _len: u64) -> Result<(), Error>

pub fn fdstat_set_flags(&self, _fdflags: Fdflags) -> Result<(), Error>

pub fn filestat_get(&self) -> Result<Filestat, Error>

pub fn filestat_set_size(&self, _st_size: u64) -> Result<(), Error>

pub fn preadv(
    &self,
    buf: &mut [IoSliceMut<'_>],
    offset: u64
) -> Result<usize, Error>

pub fn seek(&self, _offset: SeekFrom) -> Result<u64, Error>

pub fn read_vectored(&self, iovs: &mut [IoSliceMut<'_>]) -> Result<usize, Error>

pub fn create_directory(&self, _path: &str) -> Result<(), Error>

pub fn openat(
    &self,
    _path: &str,
    _read: bool,
    _write: bool,
    _oflags: Oflags,
    _fd_flags: Fdflags
) -> Result<Box<dyn Handle + 'static, Global>, Error>

pub fn link(
    &self,
    _old_path: &str,
    _new_handle: Box<dyn Handle + 'static, Global>,
    _new_path: &str,
    _follow: bool
) -> Result<(), Error>

pub fn readlink(&self, _path: &str, _buf: &mut [u8]) -> Result<usize, Error>

pub fn readlinkat(&self, _path: &str) -> Result<String, Error>

pub fn rename(
    &self,
    _old_path: &str,
    _new_handle: Box<dyn Handle + 'static, Global>,
    _new_path: &str
) -> Result<(), Error>

pub fn remove_directory(&self, _path: &str) -> Result<(), Error>

pub fn symlink(&self, _old_path: &str, _new_path: &str) -> Result<(), Error>

pub fn unlink_file(&self, _path: &str) -> Result<(), Error>

fn is_directory(&self) -> bool

fn is_tty(&self) -> bool

Test whether this descriptor is considered a tty within WASI. Note that since WASI itself lacks an isatty syscall and relies on a conservative approximation, we use the same approximation here.

fn datasync(&self) -> Result<(), Error>

fn fdstat_get(&self) -> Result<Fdflags, Error>

fn filestat_set_times(
    &self,
    _atim: u64,
    _mtim: u64,
    _fst_flags: Fstflags
) -> Result<(), Error>

fn pwritev(&self, _buf: &[IoSlice<'_>], _offset: u64) -> Result<usize, Error>

fn readdir(
    &'a self,
    _cookie: u64
) -> Result<Box<dyn Iterator<Item = Result<(Dirent, String), Error>> + 'a, Global>, Error>

fn sync(&self) -> Result<(), Error>

fn write_vectored(&self, _iovs: &[IoSlice<'_>]) -> Result<usize, Error>

fn filestat_get_at(&self, _path: &str, _follow: bool) -> Result<Filestat, Error>

fn filestat_set_times_at(
    &self,
    _path: &str,
    _atim: u64,
    _mtim: u64,
    _fst_flags: Fstflags,
    _follow: bool
) -> Result<(), Error>