| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | io.rs | 4 bindings::sync::io::streams::{self, InputStream, OutputStream},
29 fn drop(&mut self, stream: Resource<OutputStream>) -> wasmtime::Result<()> { in drop()
33 fn check_write(&mut self, stream: Resource<OutputStream>) -> StreamResult<u64> { in check_write()
37 fn write(&mut self, stream: Resource<OutputStream>, bytes: Vec<u8>) -> StreamResult<()> { in write() argument
43 stream: Resource<OutputStream>, in blocking_write_and_flush() argument
53 stream: Resource<OutputStream>, in blocking_write_zeroes_and_flush() argument
63 stream: Resource<OutputStream>, in subscribe() argument
72 fn flush(&mut self, stream: Resource<OutputStream>) -> StreamResult<()> { in flush()
79 fn blocking_flush(&mut self, stream: Resource<OutputStream>) -> StreamResult<()> { in blocking_flush()
87 dst: Resource<OutputStream>, in splice() argument
[all …]
|
| H A D | tcp.rs | 292 OutputStream, Pollable, ShutdownType, TcpSocket,
332 ) -> Result<(Resource<InputStream>, Resource<OutputStream>), SocketError> { in finish_connect() argument
351 Resource<OutputStream>, in accept() argument
|
| /wasmtime-44.0.1/crates/wasi/src/cli/ |
| H A D | stdout.rs | 8 use wasmtime_wasi_io::streams::OutputStream;
17 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
32 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
47 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
62 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
75 impl OutputStream for StdioOutputStream {
|
| H A D | empty.rs | 6 use wasmtime_wasi_io::streams::{InputStream, OutputStream};
23 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
46 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
76 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
91 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
|
| H A D | mem.rs | 4 use wasmtime_wasi_io::streams::{InputStream, OutputStream};
28 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
|
| H A D | file.rs | 2 use crate::p2::{InputStream, OutputStream, Pollable, StreamError, StreamResult};
35 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
49 impl OutputStream for OutputFile {
|
| H A D | locked_async.rs | 10 use wasmtime_wasi_io::streams::{InputStream, OutputStream};
148 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
178 impl OutputStream for AsyncStdoutStream {
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | cli.rs | 6 use wasmtime_wasi_io::streams::{InputStream, OutputStream};
165 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
188 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
211 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
234 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
257 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream() argument
268 use crate::p2::{self, OutputStream};
357 async fn blocking_write_and_flush(s: &mut dyn OutputStream, mut bytes: Bytes) -> Result<()> { in blocking_write_and_flush() argument
|
| /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
30 output: &OutputStream, in blocking_close_output() argument
|
| H A D | sockets.rs | 3 use crate::wasi::io::streams::{InputStream, OutputStream, StreamError};
49 impl OutputStream { impl
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 | 126 pub trait OutputStream: Pollable { interface
272 impl Pollable for Box<dyn OutputStream> {
287 pub type DynOutputStream = Box<dyn OutputStream>;
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_tcp_streams.rs | 2 use test_programs::wasi::io::streams::{InputStream, OutputStream, StreamError};
131 output: OutputStream,
|
| H A D | p2_api_reactor.rs | 36 fn write_strings_to(o: OutputStream) -> Result<(), ()> { in write_strings_to()
|
| H A D | p2_api_proxy_streaming.rs | 322 OutgoingRequest, OutputStream,
379 struct Outgoing(Option<(OutputStream, OutgoingBody)>); in outgoing_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};
36 pub output: OnceCell<OutputStream>,
72 pub fn get_write_stream(&self) -> Result<&OutputStream, Errno> { in get_write_stream() argument
461 pub fn get_write_stream(&self, fd: Fd) -> Result<&OutputStream, Errno> { in get_write_stream() argument
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | write_stream.rs | 1 use crate::p2::{OutputStream, Pollable, StreamError};
167 impl OutputStream for AsyncWriteStream {
|
| H A D | tcp.rs | 2 DynInputStream, DynOutputStream, InputStream, OutputStream, Pollable, SocketError,
315 impl OutputStream for TcpWriteStream {
|
| H A D | pipe.rs | 19 streams::{InputStream, OutputStream, StreamError},
98 impl OutputStream for MemoryOutputPipe {
277 impl OutputStream for SinkOutputStream {
318 impl OutputStream for ClosedOutputStream {
|
| H A D | filesystem.rs | 4 use crate::p2::{InputStream, OutputStream, Pollable, StreamError, StreamResult};
283 impl OutputStream for FileOutputStream {
|
| 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};
418 body_output_stream: Option<Box<dyn OutputStream>>,
502 pub fn take_output_stream(&mut self) -> Option<Box<dyn OutputStream>> { in take_output_stream() argument
608 impl OutputStream for BodyWriteStream {
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | io.rs | 14 DynInputStream, DynOutputStream, OutputStream, Pollable, StreamError, StreamResult,
166 return match OutputStream::write( in poll_write()
236 impl<IO> OutputStream for AsyncWriteStream<IO>
|
| /wasmtime-44.0.1/crates/wasi/src/p2/host/filesystem/ |
| H A D | sync.rs | 261 ) -> FsResult<Resource<streams::OutputStream>> { in write_via_stream() argument
270 ) -> FsResult<Resource<streams::OutputStream>> { in append_via_stream() argument
|
| /wasmtime-44.0.1/crates/c-api/src/ |
| H A D | wasi.rs | 199 impl wasmtime_wasi::p2::OutputStream for CustomOutputStream {
|
| /wasmtime-44.0.1/examples/min-platform/embedding/src/ |
| H A D | wasi.rs | 40 streams::{DynInputStream, DynOutputStream, InputStream, OutputStream},
322 impl OutputStream for WriteLog {
|