| /wasmtime-44.0.1/crates/wasi/src/cli/ |
| H A D | empty.rs | 5 use tokio::io::{self, AsyncRead, AsyncWrite};
26 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
49 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
79 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
94 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
97 impl AsyncWrite for AlwaysClosed { in async_stream()
|
| H A D | stdout.rs | 7 use tokio::io::AsyncWrite;
20 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
35 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
50 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
65 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
97 impl AsyncWrite for StdioOutputStream {
|
| H A D | mem.rs | 3 use tokio::io::{AsyncRead, AsyncWrite};
31 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
|
| H A D | file.rs | 8 use tokio::io::{self, AsyncRead, AsyncWrite};
39 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
68 impl AsyncWrite for OutputFile {
|
| H A D | locked_async.rs | 8 use tokio::io::{self, AsyncRead, AsyncWrite};
140 pub fn new(budget: usize, s: impl AsyncWrite + Send + Sync + 'static) -> Self { in new()
151 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
217 impl AsyncWrite for StdioHandle<p2::pipe::AsyncWriteStream> {
|
| /wasmtime-44.0.1/crates/wasi-tls/src/ |
| H A D | lib.rs | 78 use tokio::io::{AsyncRead, AsyncWrite};
167 pub trait TlsTransport: AsyncRead + AsyncWrite + Send + Unpin + 'static {}
168 impl<T: AsyncRead + AsyncWrite + Send + Unpin + ?Sized + 'static> TlsTransport for T {}
171 pub trait TlsStream: AsyncRead + AsyncWrite + Send + Unpin + 'static {}
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p3/util/ |
| H A D | shared.rs | 4 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
32 impl<IO: AsyncWrite + Unpin> AsyncWrite for Shared<IO> {
|
| H A D | closed.rs | 6 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
22 impl AsyncWrite for Closed {
|
| H A D | pipe.rs | 3 use tokio::io::{AsyncRead, AsyncWrite, DuplexStream, ReadBuf};
32 impl AsyncWrite for Writer {
|
| H A D | deferred.rs | 3 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
87 impl<IO: AsyncWrite + Unpin> AsyncWrite for Deferred<IO> {
|
| H A D | tokio_streams.rs | 5 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
113 IO: AsyncWrite + Send + Unpin + 'static,
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | cli.rs | 4 use tokio::io::{AsyncRead, AsyncWrite, empty};
157 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync>; in async_stream()
191 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
214 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
237 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
260 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
|
| /wasmtime-44.0.1/crates/wasi-http/src/ |
| H A D | io.rs | 7 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
39 impl<T: AsyncWrite + Unpin> Write for TokioIo<T> {
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | io.rs | 9 use tokio::io::{AsyncRead, AsyncWrite, AsyncWriteExt};
138 impl AsyncWrite for WasiStreamWriter {
208 IO: AsyncWrite + Send + Unpin + 'static,
238 IO: AsyncWrite + Send + Unpin + 'static,
260 IO: AsyncWrite + Send + Unpin + 'static,
279 IO: AsyncWrite + Send + Unpin + 'static,
|
| /wasmtime-44.0.1/crates/c-api/src/ |
| H A D | wasi.rs | 11 use tokio::io::{self, AsyncWrite};
222 impl AsyncWrite for CustomOutputStream {
245 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | write_stream.rs | 93 async fn work<T: tokio::io::AsyncWrite + Send + 'static>(&self, writer: T) { in work()
143 pub fn new<T: tokio::io::AsyncWrite + Send + 'static>(write_budget: usize, writer: T) -> Self { in new()
|
| H A D | pipe.rs | 14 use tokio::io::{self, AsyncRead, AsyncWrite};
130 impl AsyncWrite for MemoryOutputPipe {
340 use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt};
371 pub fn simplex(size: usize) -> (impl AsyncRead, impl AsyncWrite) { in simplex() argument
|
| /wasmtime-44.0.1/crates/wasi-tls/src/providers/ |
| H A D | nativetls.rs | 45 impl tokio::io::AsyncWrite for NativeTlsStream {
|
| H A D | openssl.rs | 54 impl tokio::io::AsyncWrite for OpenSslStream {
|
| /wasmtime-44.0.1/crates/wasi/src/p3/cli/ |
| H A D | host.rs | 14 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
85 tx: Pin<Box<dyn AsyncWrite + Send + Sync>>,
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/ |
| H A D | request.rs | 275 use tokio::io::{AsyncRead, AsyncWrite}; in default_send_request()
278 trait TokioStream: AsyncRead + AsyncWrite + Send + Sync + Unpin + 'static { in default_send_request()
286 impl<T> TokioStream for T where T: AsyncRead + AsyncWrite + Send + Sync + Unpin + 'static {} in default_send_request()
|
| /wasmtime-44.0.1/crates/gdbstub-component/src/ |
| H A D | lib.rs | 25 io::{AsyncRead, AsyncWrite},
|
| /wasmtime-44.0.1/src/commands/ |
| H A D | serve.rs | 22 use tokio::io::{self, AsyncWrite};
1360 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
1395 impl AsyncWrite for LogStream {
|