| /wasmtime-44.0.1/crates/wasi-io/src/ |
| H A D | impls.rs | 3 use crate::streams::{DynInputStream, DynOutputStream, StreamError, StreamResult};
121 async fn drop(&mut self, stream: Resource<DynOutputStream>) -> Result<()> { in drop()
126 fn check_write(&mut self, stream: Resource<DynOutputStream>) -> StreamResult<u64> { in check_write()
131 fn write(&mut self, stream: Resource<DynOutputStream>, bytes: Vec<u8>) -> StreamResult<()> { in write() argument
136 fn subscribe(&mut self, stream: Resource<DynOutputStream>) -> Result<Resource<DynPollable>> { in subscribe()
142 stream: Resource<DynOutputStream>, in blocking_write_and_flush() argument
158 stream: Resource<DynOutputStream>, in blocking_write_zeroes_and_flush() argument
178 fn flush(&mut self, stream: Resource<DynOutputStream>) -> StreamResult<()> { in flush()
183 async fn blocking_flush(&mut self, stream: Resource<DynOutputStream>) -> StreamResult<()> { in blocking_flush()
192 dest: Resource<DynOutputStream>, in splice() argument
[all …]
|
| H A D | bindings.rs | 6 "wasi:io/streams.output-stream": crate::streams::DynOutputStream,
|
| H A D | streams.rs | 287 pub type DynOutputStream = Box<dyn OutputStream>; typedef
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | host.rs | 5 use wasmtime_wasi::p2::{DynInputStream, DynOutputStream, DynPollable, IoError};
29 output: Resource<DynOutputStream>, in new() argument
63 let output = Box::new(write_stream) as DynOutputStream; in finish()
79 WasiFuture<Result<(HostClientConnection, DynInputStream, DynOutputStream), IoError>>,
107 Resource<DynOutputStream>, in get() argument
|
| H A D | io.rs | 14 DynInputStream, DynOutputStream, OutputStream, Pollable, StreamError, StreamResult,
132 pub(crate) struct WasiStreamWriter(FutureState<DynOutputStream>);
134 pub(crate) fn new(stream: DynOutputStream) -> Self { in new()
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | stdio.rs | 23 fn get_stdout(&mut self) -> Result<Resource<streams::DynOutputStream>, wasmtime::Error> { in get_stdout() argument
30 fn get_stderr(&mut self) -> Result<Resource<streams::DynOutputStream>, wasmtime::Error> { in get_stderr() argument
|
| 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
25 let output: DynOutputStream = Box::new(TcpWriteStream(writer)); in p2_streams()
|
| H A D | bindings.rs | 182 "wasi:io/streams.output-stream": wasmtime_wasi_io::streams::DynOutputStream,
|
| H A D | mod.rs | 257 DynInputStream, DynOutputStream, Error as IoError, InputStream, OutputStream, StreamError,
|
| /wasmtime-44.0.1/examples/min-platform/embedding/src/ |
| H A D | wasi.rs | 40 streams::{DynInputStream, DynOutputStream, InputStream, OutputStream},
559 fn get_stdout(&mut self) -> Result<Resource<DynOutputStream>> { in get_stdout() argument
560 let stdout: DynOutputStream = Box::new(self.stdout.clone()); in get_stdout()
566 fn get_stderr(&mut self) -> Result<Resource<DynOutputStream>> { in get_stderr() argument
567 let stderr: DynOutputStream = Box::new(self.stderr.clone()); in get_stderr()
649 ) -> Result<Result<Resource<DynOutputStream>, wasi::filesystem::types::ErrorCode>> { in write_via_stream() argument
655 ) -> Result<Result<Resource<DynOutputStream>, wasi::filesystem::types::ErrorCode>> { in append_via_stream() argument
|
| /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
102 Resource<DynOutputStream>, in accept() argument
|
| H A D | filesystem.rs | 11 use wasmtime_wasi_io::streams::{DynInputStream, DynOutputStream};
401 ) -> FsResult<Resource<DynOutputStream>> { in write_via_stream() argument
411 let writer: DynOutputStream = Box::new(writer); in write_via_stream()
422 ) -> FsResult<Resource<DynOutputStream>> { in append_via_stream() argument
432 let appender: DynOutputStream = Box::new(appender); in append_via_stream()
|
| /wasmtime-44.0.1/crates/wasi/tests/all/p2/ |
| H A D | api.rs | 169 let stream: wasmtime_wasi::p2::DynOutputStream = Box::new(writepipe.clone()); in p2_api_reactor()
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | types_impl.rs | 16 use wasmtime_wasi::p2::{DynInputStream, DynOutputStream, DynPollable};
689 ) -> wasmtime::Result<Result<Resource<DynOutputStream>, ()>> { in write() argument
|