Searched defs:AsyncRead (Results 1 – 13 of 13) sorted by relevance
| /external/rust/crates/combine/src/stream/ |
| D | decoder.rs | 158 pub async fn __before_parse_tokio_02<R>(&mut self, mut reader: Pin<&mut R>) -> io::Result<()> in __before_parse_tokio_02()
161 C: crate::stream::buf_reader::CombineRead<R, dyn tokio_02_dep::io::AsyncRead>, in __before_parse_tokio_02()
177 pub async fn __before_parse_tokio_03<R>(&mut self, mut reader: Pin<&mut R>) -> io::Result<()> in __before_parse_tokio_03()
180 C: crate::stream::buf_reader::CombineRead<R, dyn tokio_03_dep::io::AsyncRead>, in __before_parse_tokio_03()
196 pub async fn __before_parse_tokio<R>(&mut self, mut reader: Pin<&mut R>) -> io::Result<()> in __before_parse_tokio()
199 C: crate::stream::buf_reader::CombineRead<R, dyn tokio_dep::io::AsyncRead>, in __before_parse_tokio()
215 pub async fn __before_parse_async<R>(&mut self, reader: Pin<&mut R>) -> io::Result<()> in __before_parse_async()
|
| D | buf_reader.rs | 287 read: Pin<&mut impl tokio_03_dep::io::AsyncRead>, in tokio_03_read_buf()
319 read: Pin<&mut impl tokio_dep::io::AsyncRead>, in tokio_read_buf()
502 R: futures_io_03::AsyncRead, in poll_extend_buf()
|
| /external/rust/crates/tokio/src/io/ |
| D | async_read.rs | 43 pub trait AsyncRead { trait
76 impl<T: ?Sized + AsyncRead + Unpin> AsyncRead for &mut T { impl
94 impl AsyncRead for &[u8] { impl
|
| /external/rust/crates/futures-io/src/ |
| D | lib.rs | 44 pub trait AsyncRead { trait
324 impl<T: ?Sized + AsyncRead + Unpin> AsyncRead for &mut T { impl
370 impl AsyncRead for &[u8] { impl
|
| /external/rust/crates/tokio/src/io/util/ |
| D | chain.rs | 24 T: AsyncRead, in chain()
25 U: AsyncRead, in chain()
|
| /external/rust/crates/futures-util/src/io/ |
| D | copy.rs | 36 R: AsyncRead, in copy()
|
| D | mod.rs | 175 R: AsyncRead, in chain()
828 pub(crate) fn assert_read<R>(reader: R) -> R in assert_read()
|
| /external/rust/crates/tokio-util/src/ |
| D | lib.rs | 108 pub fn poll_read_buf<T: AsyncRead, B: BufMut>( in poll_read_buf()
|
| /external/rust/crates/tokio-util/src/io/ |
| D | inspect.rs | 29 R: AsyncRead, in new()
|
| /external/cronet/third_party/boringssl/src/ssl/test/ |
| D | async_bio.cc | 74 static int AsyncRead(BIO *bio, char *out, int outl) { in AsyncRead() function
|
| /external/rust/crates/quiche/deps/boringssl/src/ssl/test/ |
| D | async_bio.cc | 74 static int AsyncRead(BIO *bio, char *out, int outl) { in AsyncRead() function
|
| /external/boringssl/src/ssl/test/ |
| D | async_bio.cc | 74 static int AsyncRead(BIO *bio, char *out, int outl) { in AsyncRead() function
|
| /external/rust/crates/tokio-util/src/codec/ |
| D | length_delimited.rs | 962 pub fn new_read<T>(&self, upstream: T) -> FramedRead<T, LengthDelimitedCodec> in new_read()
|