| /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};
23 impl<IO: AsyncRead + Unpin> AsyncRead for Shared<IO> {
|
| H A D | closed.rs | 6 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
13 impl AsyncRead for Closed {
|
| H A D | pipe.rs | 3 use tokio::io::{AsyncRead, AsyncWrite, DuplexStream, ReadBuf};
22 impl AsyncRead for Reader {
|
| H A D | deferred.rs | 3 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
77 impl<IO: AsyncRead + Unpin> AsyncRead for Deferred<IO> {
|
| H A D | tokio_streams.rs | 5 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
37 IO: AsyncRead + Send + Unpin + 'static,
|
| /wasmtime-44.0.1/crates/wasi/src/cli/ |
| H A D | empty.rs | 5 use tokio::io::{self, AsyncRead, AsyncWrite};
18 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
41 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
64 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
|
| H A D | mem.rs | 3 use tokio::io::{AsyncRead, AsyncWrite};
16 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
|
| H A D | file.rs | 8 use tokio::io::{self, AsyncRead, AsyncWrite};
109 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
140 impl AsyncRead for InputFile {
|
| H A D | worker_thread_stdin.rs | 33 use tokio::io::{self, AsyncRead, ReadBuf};
51 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
66 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
201 impl AsyncRead for WasiStdinAsyncRead {
|
| H A D | locked_async.rs | 8 use tokio::io::{self, AsyncRead, AsyncWrite};
59 pub fn new(s: impl AsyncRead + Send + Sync + 'static) -> Self { in new()
68 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
111 impl AsyncRead for StdioHandle<p2::pipe::AsyncReadStream> {
|
| /wasmtime-44.0.1/crates/wasi/src/ |
| H A D | cli.rs | 4 use tokio::io::{AsyncRead, AsyncWrite, empty};
122 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync>; in async_stream()
183 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
206 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
229 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
252 fn async_stream(&self) -> Box<dyn AsyncRead + 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};
23 impl<T: AsyncRead + Unpin> Read for TokioIo<T> {
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | pipe.rs | 14 use tokio::io::{self, AsyncRead, AsyncWrite};
60 impl AsyncRead for MemoryInputPipe {
160 pub fn new<T: AsyncRead + Send + 'static>(reader: T) -> Self { in new()
340 use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt};
371 pub fn simplex(size: usize) -> (impl AsyncRead, impl AsyncWrite) { in simplex() argument
427 async fn finite_async_reader(contents: &[u8]) -> impl AsyncRead + Send + 'static + use<> { in finite_async_reader()
|
| /wasmtime-44.0.1/crates/wasi-tls/src/providers/ |
| H A D | nativetls.rs | 35 impl tokio::io::AsyncRead for NativeTlsStream {
|
| H A D | openssl.rs | 44 impl tokio::io::AsyncRead for OpenSslStream {
|
| /wasmtime-44.0.1/crates/wasi/src/p3/cli/ |
| H A D | host.rs | 14 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
23 rx: Pin<Box<dyn AsyncRead + 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/wasi-tls/src/p2/ |
| H A D | io.rs | 9 use tokio::io::{AsyncRead, AsyncWrite, AsyncWriteExt};
79 impl AsyncRead for WasiStreamReader {
|
| /wasmtime-44.0.1/crates/gdbstub-component/src/ |
| H A D | lib.rs | 25 io::{AsyncRead, AsyncWrite},
|