Searched refs:AsyncWriteStream (Results 1 – 6 of 6) sorted by relevance
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | write_stream.rs | 135 pub struct AsyncWriteStream { struct
140 impl AsyncWriteStream { argument
149 AsyncWriteStream { in new()
167 impl OutputStream for AsyncWriteStream { implementation
209 impl Pollable for AsyncWriteStream { implementation
|
| H A D | pipe.rs | 22 pub use crate::p2::write_stream::AsyncWriteStream;
580 let mut writer = AsyncWriteStream::new(2048, tokio::io::sink()); in sink_write_stream()
622 let mut writer = AsyncWriteStream::new(1024, writer); in closed_write_stream_()
709 let mut writer = AsyncWriteStream::new(1024, writer); in multiple_chunks_write_stream_aux()
781 let mut writer = AsyncWriteStream::new(1024, writer); in backpressure_write_stream_aux()
847 let mut writer = AsyncWriteStream::new(1024, writer); in backpressure_write_stream_with_flush_aux()
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | io.rs | 204 pub(crate) struct AsyncWriteStream<IO>(Arc<Mutex<WriteState<IO>>>); struct
206 impl<IO> AsyncWriteStream<IO> impl
211 AsyncWriteStream(Arc::new(Mutex::new(WriteState::new(io)))) in new()
229 impl<IO> Clone for AsyncWriteStream<IO> { implementation
236 impl<IO> OutputStream for AsyncWriteStream<IO> implementation
258 impl<IO> Pollable for AsyncWriteStream<IO> implementation
|
| H A D | host.rs | 10 AsyncReadStream, AsyncWriteStream, FutureOutput, WasiFuture, WasiStreamReader,
59 let write_stream = AsyncWriteStream::new(tx); in finish()
145 crate::p2::io::AsyncWriteStream<tokio::io::WriteHalf<Box<dyn TlsStream>>>,
|
| /wasmtime-44.0.1/crates/wasi/src/cli/ |
| H A D | locked_async.rs | 16 impl SharedHandleReady for p2::pipe::AsyncWriteStream { implementation
137 pub struct AsyncStdoutStream(Arc<Mutex<p2::pipe::AsyncWriteStream>>);
141 Self(Arc::new(Mutex::new(p2::pipe::AsyncWriteStream::new( in new()
217 impl AsyncWrite for StdioHandle<p2::pipe::AsyncWriteStream> {
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | cli.rs | 166 Box::new(p2::pipe::AsyncWriteStream::new( in p2_stream()
|