| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | io.rs | 4 bindings::sync::io::streams::{self, InputStream, OutputStream},
88 src: Resource<InputStream>, in splice() argument
97 src: Resource<InputStream>, in blocking_splice() argument
105 fn drop(&mut self, stream: Resource<InputStream>) -> wasmtime::Result<()> { in drop()
109 fn read(&mut self, stream: Resource<InputStream>, len: u64) -> StreamResult<Vec<u8>> { in read() argument
113 fn blocking_read(&mut self, stream: Resource<InputStream>, len: u64) -> StreamResult<Vec<u8>> { in blocking_read() argument
117 fn skip(&mut self, stream: Resource<InputStream>, len: u64) -> StreamResult<u64> { in skip() argument
121 fn blocking_skip(&mut self, stream: Resource<InputStream>, len: u64) -> StreamResult<u64> { in blocking_skip() argument
125 fn subscribe(&mut self, stream: Resource<InputStream>) -> wasmtime::Result<Resource<Pollable>> { in subscribe()
|
| H A D | tcp.rs | 291 self, Duration, HostTcpSocket, InputStream, IpAddressFamily, IpSocketAddress,
332 ) -> Result<(Resource<InputStream>, Resource<OutputStream>), SocketError> { in finish_connect() argument
350 Resource<InputStream>, in accept() argument
|
| /wasmtime-44.0.1/crates/wasi/src/cli/ |
| H A D | empty.rs | 6 use wasmtime_wasi_io::streams::{InputStream, OutputStream};
15 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
38 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
61 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
|
| H A D | mem.rs | 4 use wasmtime_wasi_io::streams::{InputStream, OutputStream};
13 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
|
| H A D | file.rs | 2 use crate::p2::{InputStream, OutputStream, Pollable, StreamError, StreamResult};
106 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
125 impl InputStream for InputFile {
|
| H A D | worker_thread_stdin.rs | 38 streams::{InputStream, StreamError},
48 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
63 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
139 impl InputStream for WasiStdin {
|
| H A D | locked_async.rs | 10 use wasmtime_wasi_io::streams::{InputStream, OutputStream};
65 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
80 impl InputStream for AsyncStdinStream {
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | cli.rs | 6 use wasmtime_wasi_io::streams::{InputStream, OutputStream};
130 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
180 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
203 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
226 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
249 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream() argument
|
| H A D | p1.rs | 280 input_stream: Resource<streams::InputStream>, in read() argument
323 stream: Resource<streams::InputStream>,
2592 inputs: Vec<Resource<crate::p2::bindings::io::streams::InputStream>>, in poll_oneoff()
|
| /wasmtime-44.0.1/crates/test-programs/src/ |
| H A D | tls.rs | 4 use crate::wasi::tls::types::{ClientConnection, ClientHandshake, InputStream, OutputStream};
9 pub fn blocking_finish(self) -> Result<(ClientConnection, InputStream, OutputStream), IoError> { in blocking_finish() argument
|
| H A D | sockets.rs | 3 use crate::wasi::io::streams::{InputStream, OutputStream, StreamError};
36 impl InputStream { implementation
159 ) -> Result<(InputStream, OutputStream), ErrorCode> { in blocking_connect() argument
173 pub fn blocking_accept(&self) -> Result<(TcpSocket, InputStream, OutputStream), ErrorCode> { in blocking_accept() argument
|
| /wasmtime-44.0.1/crates/wasi-io/src/ |
| H A D | streams.rs | 18 pub trait InputStream: Pollable { trait
279 impl Pollable for Box<dyn InputStream> {
285 pub type DynInputStream = Box<dyn InputStream>;
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_stream_pollable_traps.rs | 5 let stdin: streams::InputStream = stdin::get_stdin(); in main()
|
| H A D | p2_tcp_streams.rs | 2 use test_programs::wasi::io::streams::{InputStream, OutputStream, StreamError};
130 input: InputStream,
|
| H A D | p2_api_proxy_streaming.rs | 321 self, FutureTrailers, IncomingBody, IncomingResponse, InputStream, OutgoingBody,
470 stream: InputStream, in incoming_body()
|
| /wasmtime-44.0.1/crates/wasi-preview1-component-adapter/src/ |
| H A D | descriptors.rs | 2 use crate::bindings::wasi::io::streams::{InputStream, OutputStream};
33 pub input: OnceCell<InputStream>,
44 pub fn get_read_stream(&self) -> Result<&InputStream, Errno> { in get_read_stream() argument
454 pub fn get_read_stream(&self, fd: Fd) -> Result<&InputStream, Errno> { in get_read_stream() argument
|
| H A D | lib.rs | 2568 input_stream: &streams::InputStream, in read() argument
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | tcp.rs | 2 DynInputStream, DynOutputStream, InputStream, OutputStream, Pollable, SocketError,
109 impl InputStream for TcpReadStream {
|
| H A D | pipe.rs | 19 streams::{InputStream, OutputStream, StreamError},
42 impl InputStream for MemoryInputPipe {
207 impl InputStream for AsyncReadStream {
302 impl InputStream for ClosedInputStream {
|
| H A D | filesystem.rs | 4 use crate::p2::{InputStream, OutputStream, Pollable, StreamError, StreamResult};
116 impl InputStream for FileInputStream {
|
| H A D | mod.rs | 257 DynInputStream, DynOutputStream, Error as IoError, InputStream, OutputStream, StreamError,
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | body.rs | 15 use wasmtime_wasi::p2::{InputStream, OutputStream, Pollable, StreamError};
236 impl InputStream for HostIncomingBodyStream {
|
| /wasmtime-44.0.1/examples/min-platform/embedding/src/ |
| H A D | wasi.rs | 40 streams::{DynInputStream, DynOutputStream, InputStream, OutputStream},
297 impl InputStream for NeverReadable {
|
| /wasmtime-44.0.1/crates/wasi/src/p2/host/filesystem/ |
| H A D | sync.rs | 251 ) -> FsResult<Resource<streams::InputStream>> { in read_via_stream() argument
|