Searched refs:AsyncReadStream (Results 1 – 5 of 5) sorted by relevance
150 pub struct AsyncReadStream { struct157 impl AsyncReadStream { argument182 AsyncReadStream { in new()207 impl InputStream for AsyncReadStream { implementation266 impl Pollable for AsyncReadStream { implementation380 let mut reader = AsyncReadStream::new(tokio::io::empty()); in empty_read_stream()405 let mut reader = AsyncReadStream::new(tokio::io::repeat(0)); in infinite_read_stream()435 let mut reader = AsyncReadStream::new(finite_async_reader(&[1; 123]).await); in finite_read_stream()472 let mut reader = AsyncReadStream::new(r); in multiple_chunks_read_stream()537 let mut reader = AsyncReadStream::new(r); in backpressure_read_stream()
22 impl SharedHandleReady for p2::pipe::AsyncReadStream { implementation56 pub struct AsyncStdinStream(Arc<Mutex<p2::pipe::AsyncReadStream>>);60 Self(Arc::new(Mutex::new(p2::pipe::AsyncReadStream::new(s)))) in new()111 impl AsyncRead for StdioHandle<p2::pipe::AsyncReadStream> {
10 AsyncReadStream, AsyncWriteStream, FutureOutput, WasiFuture, WasiStreamReader,62 let input = Box::new(AsyncReadStream::new(rx)) as DynInputStream; in finish()
202 pub(crate) use wasmtime_wasi::p2::pipe::AsyncReadStream;
131 Box::new(p2::pipe::AsyncReadStream::new(Pin::from( in p2_stream()