| /external/rust/crates/tokio/src/io/ |
| D | async_buf_read.rs | 23 pub trait AsyncBufRead: AsyncRead { trait
77 impl<T: ?Sized + AsyncBufRead + Unpin> AsyncBufRead for Box<T> {
81 impl<T: ?Sized + AsyncBufRead + Unpin> AsyncBufRead for &mut T { impl
85 impl<P> AsyncBufRead for Pin<P>
88 P::Target: AsyncBufRead,
99 impl AsyncBufRead for &[u8] { impl
109 impl<T: AsRef<[u8]> + Unpin> AsyncBufRead for io::Cursor<T> {
|
| /external/rust/crates/tokio-util/src/ |
| D | compat.rs | 149 impl<T> tokio::io::AsyncBufRead for Compat<T>
151 T: futures_io::AsyncBufRead,
157 futures_io::AsyncBufRead::poll_fill_buf(self.project().inner, cx) in poll_fill_buf()
161 futures_io::AsyncBufRead::consume(self.project().inner, amt) in consume()
165 impl<T> futures_io::AsyncBufRead for Compat<T>
167 T: tokio::io::AsyncBufRead,
173 tokio::io::AsyncBufRead::poll_fill_buf(self.project().inner, cx) in poll_fill_buf()
177 tokio::io::AsyncBufRead::consume(self.project().inner, amt) in consume()
|
| D | either.rs | 8 use tokio::io::{AsyncBufRead, AsyncRead, AsyncSeek, AsyncWrite, ReadBuf, Result};
109 impl<L, R> AsyncBufRead for Either<L, R>
111 L: AsyncBufRead,
112 R: AsyncBufRead,
|
| /external/rust/crates/tokio/src/io/util/ |
| D | split.rs | 2 use crate::io::AsyncBufRead;
30 R: AsyncBufRead, in split()
42 R: AsyncBufRead + Unpin,
70 R: AsyncBufRead,
|
| D | lines.rs | 2 use crate::io::AsyncBufRead;
34 R: AsyncBufRead, in lines()
46 R: AsyncBufRead + Unpin,
96 R: AsyncBufRead,
|
| D | read_until.rs | 1 use crate::io::AsyncBufRead;
35 R: AsyncBufRead + ?Sized + Unpin, in read_until()
46 pub(super) fn read_until_internal<R: AsyncBufRead + ?Sized>( in read_until_internal()
72 impl<R: AsyncBufRead + ?Sized + Unpin> Future for ReadUntil<'_, R> {
|
| D | async_buf_read_ext.rs | 6 use crate::io::AsyncBufRead;
12 pub trait AsyncBufReadExt: AsyncBufRead {
351 impl<R: AsyncBufRead + ?Sized> AsyncBufReadExt for R {}
|
| D | chain.rs | 1 use crate::io::{AsyncBufRead, AsyncRead, ReadBuf};
107 impl<T, U> AsyncBufRead for Chain<T, U>
109 T: AsyncBufRead,
110 U: AsyncBufRead,
|
| D | fill_buf.rs | 1 use crate::io::AsyncBufRead;
23 R: AsyncBufRead + ?Sized + Unpin, in fill_buf()
31 impl<'a, R: AsyncBufRead + ?Sized + Unpin> Future for FillBuf<'a, R> {
|
| D | read_line.rs | 2 use crate::io::AsyncBufRead;
35 R: AsyncBufRead + ?Sized + Unpin, in read_line()
94 pub(super) fn read_line_internal<R: AsyncBufRead + ?Sized>( in read_line_internal()
111 impl<R: AsyncBufRead + ?Sized + Unpin> Future for ReadLine<'_, R> {
|
| D | copy_buf.rs | 1 use crate::io::{AsyncBufRead, AsyncWrite};
56 R: AsyncBufRead + Unpin + ?Sized,
69 R: AsyncBufRead + Unpin + ?Sized,
|
| D | take.rs | 1 use crate::io::{AsyncBufRead, AsyncRead, ReadBuf};
106 impl<R: AsyncBufRead> AsyncBufRead for Take<R> {
|
| /external/rust/crates/futures-io/src/ |
| D | lib.rs | 251 pub trait AsyncBufRead: AsyncRead { interface
518 impl<T: ?Sized + AsyncBufRead + Unpin> AsyncBufRead for Box<T> {
522 impl<T: ?Sized + AsyncBufRead + Unpin> AsyncBufRead for &mut T { impl
526 impl<P> AsyncBufRead for Pin<P>
529 P::Target: AsyncBufRead,
552 impl AsyncBufRead for &[u8] { impl
|
| /external/rust/crates/futures-util/src/io/ |
| D | read_until.rs | 4 use futures_io::AsyncBufRead;
21 impl<'a, R: AsyncBufRead + ?Sized + Unpin> ReadUntil<'a, R> {
27 pub(super) fn read_until_internal<R: AsyncBufRead + ?Sized>( in read_until_internal()
53 impl<R: AsyncBufRead + ?Sized + Unpin> Future for ReadUntil<'_, R> {
|
| D | read_line.rs | 5 use futures_io::AsyncBufRead;
23 impl<'a, R: AsyncBufRead + ?Sized + Unpin> ReadLine<'a, R> {
29 pub(super) fn read_line_internal<R: AsyncBufRead + ?Sized>( in read_line_internal()
50 impl<R: AsyncBufRead + ?Sized + Unpin> Future for ReadLine<'_, R> {
|
| D | lines.rs | 5 use futures_io::AsyncBufRead;
24 impl<R: AsyncBufRead> Lines<R> {
30 impl<R: AsyncBufRead> Stream for Lines<R> {
|
| D | chain.rs | 3 use futures_io::{AsyncBufRead, AsyncRead, IoSliceMut};
114 impl<T, U> AsyncBufRead for Chain<T, U>
116 T: AsyncBufRead,
117 U: AsyncBufRead,
|
| D | fill_buf.rs | 3 use futures_io::AsyncBufRead;
16 impl<'a, R: AsyncBufRead + ?Sized + Unpin> FillBuf<'a, R> {
24 R: AsyncBufRead + ?Sized + Unpin,
|
| D | copy_buf.rs | 4 use futures_io::{AsyncBufRead, AsyncWrite};
36 R: AsyncBufRead, in copy_buf() argument
56 R: AsyncBufRead,
|
| D | take.rs | 3 use futures_io::{AsyncBufRead, AsyncRead};
103 impl<R: AsyncBufRead> AsyncBufRead for Take<R> {
|
| D | copy_buf_abortable.rs | 4 use futures_io::{AsyncBufRead, AsyncWrite};
52 R: AsyncBufRead, in copy_buf_abortable() argument
83 R: AsyncBufRead,
|
| D | empty.rs | 2 use futures_io::{AsyncBufRead, AsyncRead};
46 impl AsyncBufRead for Empty {
|
| /external/rust/crates/futures-test/src/io/ |
| D | limited.rs | 1 use futures_io::{self as io, AsyncBufRead, AsyncRead, AsyncWrite};
83 impl<R: AsyncBufRead> AsyncBufRead for Limited<R> {
|
| /external/rust/crates/futures/tests/ |
| D | object_safety.rs | 34 use futures::io::{AsyncBufRead, AsyncRead, AsyncSeek, AsyncWrite}; in io()
39 assert_is_object_safe::<&dyn AsyncBufRead>(); in io()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | lines.rs | 6 use tokio::io::{AsyncBufRead, Lines};
39 impl<R: AsyncBufRead> Stream for LinesStream<R> {
|