Struct IoImpl

#[repr(transparent)]
pub struct IoImpl<T>(pub T);

A small newtype wrapper which serves as the basis for implementations of Host WASI traits in this crate.

This type is used as the basis for the implementation of all Host traits generated by bindgen! for WASI interfaces.

You don’t need to use this type if you are using the root add_to_linker_async in this crate.

If you’re calling the add_to_linker functions generated by bindgen! from the bindings module, you’ll want to create a value of this type in the closures added to a Linker.

Tuple Fields

0: T

Trait Implementations

impl<T> Host for IoImpl<T>

where T: IoView,

async fn poll( &mut self, pollables: Vec<Resource<DynPollable>>, ) -> Result<Vec<u32>, Error>

Poll for completion on a set of pollables.

impl<T> Host for IoImpl<T>

where T: IoView,

fn convert_stream_error( &mut self, err: StreamError, ) -> Result<StreamError, Error>

impl<T> Host for IoImpl<T>

where T: IoView,

fn convert_stream_error(&mut self, err: StreamError) -> Result<StreamError>

impl<T> Host for IoImpl<T>

where T: IoView,

fn poll(&mut self, pollables: Vec<Resource<DynPollable>>) -> Result<Vec<u32>>

Poll for completion on a set of pollables.

impl<T> HostError for IoImpl<T>

where T: IoView,

fn drop(&mut self, err: Resource<Error>) -> Result<(), Error>

fn to_debug_string(&mut self, err: Resource<Error>) -> Result<String, Error>

Returns a string that is suitable to assist humans in debugging this error.

impl<T> HostInputStream for IoImpl<T>

where T: IoView,

async fn drop( &mut self, stream: Resource<Box<dyn InputStream>>, ) -> Result<(), Error>

fn read( &mut self, stream: Resource<Box<dyn InputStream>>, len: u64, ) -> Result<Vec<u8>, StreamError>

Perform a non-blocking read from the stream.

async fn blocking_read( &mut self, stream: Resource<Box<dyn InputStream>>, len: u64, ) -> Result<Vec<u8>, StreamError>

Read bytes from a stream, after blocking until at least one byte can be read. Except for blocking, behavior is identical to read.

fn skip( &mut self, stream: Resource<Box<dyn InputStream>>, len: u64, ) -> Result<u64, StreamError>

Skip bytes from a stream. Returns number of bytes skipped.

async fn blocking_skip( &mut self, stream: Resource<Box<dyn InputStream>>, len: u64, ) -> Result<u64, StreamError>

Skip bytes from a stream, after blocking until at least one byte can be skipped. Except for blocking behavior, identical to skip.

fn subscribe( &mut self, stream: Resource<Box<dyn InputStream>>, ) -> Result<Resource<DynPollable>, Error>

Create a pollable which will resolve once either the specified stream has bytes available to read or the other end of the stream has been closed. The created pollable is a child resource of the input-stream. Implementations may trap if the input-stream is dropped before all derived pollables created with this function are dropped.

impl<T> HostInputStream for IoImpl<T>

where T: IoView,

fn drop(&mut self, stream: Resource<InputStream>) -> Result<()>

fn read( &mut self, stream: Resource<InputStream>, len: u64, ) -> StreamResult<Vec<u8>>

Perform a non-blocking read from the stream.

fn blocking_read( &mut self, stream: Resource<InputStream>, len: u64, ) -> StreamResult<Vec<u8>>

Read bytes from a stream, after blocking until at least one byte can be read. Except for blocking, behavior is identical to read.

fn skip(&mut self, stream: Resource<InputStream>, len: u64) -> StreamResult<u64>

Skip bytes from a stream. Returns number of bytes skipped.

fn blocking_skip( &mut self, stream: Resource<InputStream>, len: u64, ) -> StreamResult<u64>

Skip bytes from a stream, after blocking until at least one byte can be skipped. Except for blocking behavior, identical to skip.

fn subscribe( &mut self, stream: Resource<InputStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once either the specified stream has bytes available to read or the other end of the stream has been closed. The created pollable is a child resource of the input-stream. Implementations may trap if the input-stream is dropped before all derived pollables created with this function are dropped.

impl<T> HostOutputStream for IoImpl<T>

where T: IoView,

async fn drop( &mut self, stream: Resource<Box<dyn OutputStream>>, ) -> Result<(), Error>

fn check_write( &mut self, stream: Resource<Box<dyn OutputStream>>, ) -> Result<u64, StreamError>

Check readiness for writing. This function never blocks.

fn write( &mut self, stream: Resource<Box<dyn OutputStream>>, bytes: Vec<u8>, ) -> Result<(), StreamError>

Perform a write. This function never blocks.

fn subscribe( &mut self, stream: Resource<Box<dyn OutputStream>>, ) -> Result<Resource<DynPollable>, Error>

Create a pollable which will resolve once the output-stream is ready for more writing, or an error has occurred. When this pollable is ready, check-write will return ok(n) with n>0, or an error.

async fn blocking_write_and_flush( &mut self, stream: Resource<Box<dyn OutputStream>>, bytes: Vec<u8>, ) -> Result<(), StreamError>

Perform a write of up to 4096 bytes, and then flush the stream. Block until all of these operations are complete, or an error occurs.

async fn blocking_write_zeroes_and_flush( &mut self, stream: Resource<Box<dyn OutputStream>>, len: u64, ) -> Result<(), StreamError>

Perform a write of up to 4096 zeroes, and then flush the stream. Block until all of these operations are complete, or an error occurs.

fn write_zeroes( &mut self, stream: Resource<Box<dyn OutputStream>>, len: u64, ) -> Result<(), StreamError>

Write zeroes to a stream.

fn flush( &mut self, stream: Resource<Box<dyn OutputStream>>, ) -> Result<(), StreamError>

Request to flush buffered output. This function never blocks.

async fn blocking_flush( &mut self, stream: Resource<Box<dyn OutputStream>>, ) -> Result<(), StreamError>

Request to flush buffered output, and block until flush completes and stream is ready for writing again.

fn splice( &mut self, dest: Resource<Box<dyn OutputStream>>, src: Resource<Box<dyn InputStream>>, len: u64, ) -> Result<u64, StreamError>

Read from one stream and write to another.

async fn blocking_splice( &mut self, dest: Resource<Box<dyn OutputStream>>, src: Resource<Box<dyn InputStream>>, len: u64, ) -> Result<u64, StreamError>

Read from one stream and write to another, with blocking.

impl<T> HostOutputStream for IoImpl<T>

where T: IoView,

fn drop(&mut self, stream: Resource<OutputStream>) -> Result<()>

fn check_write(&mut self, stream: Resource<OutputStream>) -> StreamResult<u64>

Check readiness for writing. This function never blocks.

fn write( &mut self, stream: Resource<OutputStream>, bytes: Vec<u8>, ) -> StreamResult<()>

Perform a write. This function never blocks.

fn blocking_write_and_flush( &mut self, stream: Resource<OutputStream>, bytes: Vec<u8>, ) -> StreamResult<()>

Perform a write of up to 4096 bytes, and then flush the stream. Block until all of these operations are complete, or an error occurs.

fn blocking_write_zeroes_and_flush( &mut self, stream: Resource<OutputStream>, len: u64, ) -> StreamResult<()>

Perform a write of up to 4096 zeroes, and then flush the stream. Block until all of these operations are complete, or an error occurs.

fn subscribe( &mut self, stream: Resource<OutputStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the output-stream is ready for more writing, or an error has occurred. When this pollable is ready, check-write will return ok(n) with n>0, or an error.

fn write_zeroes( &mut self, stream: Resource<OutputStream>, len: u64, ) -> StreamResult<()>

Write zeroes to a stream.

fn flush(&mut self, stream: Resource<OutputStream>) -> StreamResult<()>

Request to flush buffered output. This function never blocks.

fn blocking_flush(&mut self, stream: Resource<OutputStream>) -> StreamResult<()>

Request to flush buffered output, and block until flush completes and stream is ready for writing again.

fn splice( &mut self, dst: Resource<OutputStream>, src: Resource<InputStream>, len: u64, ) -> StreamResult<u64>

Read from one stream and write to another.

fn blocking_splice( &mut self, dst: Resource<OutputStream>, src: Resource<InputStream>, len: u64, ) -> StreamResult<u64>

Read from one stream and write to another, with blocking.

impl<T> HostPollable for IoImpl<T>

where T: IoView,

async fn block(&mut self, pollable: Resource<DynPollable>) -> Result<(), Error>

block returns immediately if the pollable is ready, and otherwise blocks until ready.

async fn ready( &mut self, pollable: Resource<DynPollable>, ) -> Result<bool, Error>

Return the readiness of a pollable. This function never blocks.

fn drop(&mut self, pollable: Resource<DynPollable>) -> Result<(), Error>

impl<T> HostPollable for IoImpl<T>

where T: IoView,

fn ready(&mut self, pollable: Resource<DynPollable>) -> Result<bool>

Return the readiness of a pollable. This function never blocks.

fn block(&mut self, pollable: Resource<DynPollable>) -> Result<()>

block returns immediately if the pollable is ready, and otherwise blocks until ready.

fn drop(&mut self, pollable: Resource<DynPollable>) -> Result<()>

impl<T> IoView for IoImpl<T>

where T: IoView,

fn table(&mut self) -> &mut ResourceTable

Yields mutable access to the internal resource management that this context contains.

impl<T> Host for IoImpl<T>

where T: IoView,