| /wasmtime-44.0.1/crates/wasi-io/src/ |
| H A D | impls.rs | 3 use crate::streams::{DynInputStream, DynOutputStream, StreamError, StreamResult};
193 src: Resource<DynInputStream>, in splice() argument
222 src: Resource<DynInputStream>, in blocking_splice() argument
250 async fn drop(&mut self, stream: Resource<DynInputStream>) -> Result<()> { in drop()
255 fn read(&mut self, stream: Resource<DynInputStream>, len: u64) -> StreamResult<Vec<u8>> { in read() argument
264 stream: Resource<DynInputStream>, in blocking_read() argument
273 fn skip(&mut self, stream: Resource<DynInputStream>, len: u64) -> StreamResult<u64> { in skip() argument
281 stream: Resource<DynInputStream>, in blocking_skip() argument
289 fn subscribe(&mut self, stream: Resource<DynInputStream>) -> Result<Resource<DynPollable>> { in subscribe()
|
| H A D | bindings.rs | 5 "wasi:io/streams.input-stream": crate::streams::DynInputStream,
|
| H A D | streams.rs | 285 pub type DynInputStream = Box<dyn InputStream>; typedef
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | host.rs | 5 use wasmtime_wasi::p2::{DynInputStream, DynOutputStream, DynPollable, IoError};
28 input: Resource<DynInputStream>, in new() argument
62 let input = Box::new(AsyncReadStream::new(rx)) as DynInputStream; in finish()
79 WasiFuture<Result<(HostClientConnection, DynInputStream, DynOutputStream), IoError>>,
106 Resource<DynInputStream>, in get() argument
|
| H A D | io.rs | 14 DynInputStream, DynOutputStream, OutputStream, Pollable, StreamError, StreamResult,
73 pub(crate) struct WasiStreamReader(FutureState<DynInputStream>);
75 pub(crate) fn new(stream: DynInputStream) -> Self { in new()
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | tcp.rs | 2 DynInputStream, DynOutputStream, InputStream, OutputStream, Pollable, SocketError,
17 pub(crate) fn p2_streams(&mut self) -> SocketResult<(DynInputStream, DynOutputStream)> { in p2_streams() argument
24 let input: DynInputStream = Box::new(TcpReadStream(reader)); in p2_streams()
|
| H A D | stdio.rs | 16 fn get_stdin(&mut self) -> Result<Resource<streams::DynInputStream>, wasmtime::Error> { in get_stdin() argument
|
| H A D | bindings.rs | 181 "wasi:io/streams.input-stream": wasmtime_wasi_io::streams::DynInputStream,
|
| H A D | mod.rs | 257 DynInputStream, DynOutputStream, Error as IoError, InputStream, OutputStream, StreamError,
|
| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | tcp.rs | 11 streams::{DynInputStream, DynOutputStream},
70 ) -> SocketResult<(Resource<DynInputStream>, Resource<DynOutputStream>)> { in finish_connect() argument
101 Resource<DynInputStream>, in accept() argument
|
| H A D | filesystem.rs | 11 use wasmtime_wasi_io::streams::{DynInputStream, DynOutputStream};
380 ) -> FsResult<Resource<DynInputStream>> { in read_via_stream() argument
389 let reader: DynInputStream = Box::new(FileInputStream::new(f, offset)); in read_via_stream()
|
| /wasmtime-44.0.1/examples/min-platform/embedding/src/ |
| H A D | wasi.rs | 40 streams::{DynInputStream, DynOutputStream, InputStream, OutputStream},
552 fn get_stdin(&mut self) -> Result<Resource<DynInputStream>> { in get_stdin() argument
553 let stdin: DynInputStream = Box::new(NeverReadable); in get_stdin()
642 ) -> Result<Result<Resource<DynInputStream>, wasi::filesystem::types::ErrorCode>> { in read_via_stream() argument
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | types_impl.rs | 16 use wasmtime_wasi::p2::{DynInputStream, DynOutputStream, DynPollable};
519 ) -> wasmtime::Result<Result<Resource<DynInputStream>, ()>> { in stream() argument
523 let stream: DynInputStream = Box::new(stream); in stream()
|