| /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/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 | 4 use futures_io::AsyncBufRead;
23 impl<'a, R: AsyncBufRead + ?Sized + Unpin> ReadLine<'a, R> {
34 pub(super) fn read_line_internal<R: AsyncBufRead + ?Sized>( in read_line_internal()
55 impl<R: AsyncBufRead + ?Sized + Unpin> Future for ReadLine<'_, R> {
|
| D | fill_buf.rs | 3 use futures_io::AsyncBufRead;
16 impl<'a, R: AsyncBufRead + ?Sized + Unpin> FillBuf<'a, R> {
23 where R: AsyncBufRead + ?Sized + Unpin,
|
| D | lines.rs | 4 use futures_io::AsyncBufRead;
24 impl<R: AsyncBufRead> Lines<R> {
35 impl<R: AsyncBufRead> Stream for Lines<R> {
|
| D | copy_buf.rs | 4 use futures_io::{AsyncBufRead, AsyncWrite};
36 R: AsyncBufRead, in copy_buf() argument
59 where R: AsyncBufRead,
|
| D | chain.rs | 5 use futures_io::{AsyncBufRead, AsyncRead, IoSliceMut};
130 impl<T, U> AsyncBufRead for Chain<T, U>
132 T: AsyncBufRead,
133 U: AsyncBufRead,
|
| D | take.rs | 5 use futures_io::{AsyncRead, AsyncBufRead};
111 impl<R: AsyncBufRead> AsyncBufRead for Take<R> {
|
| D | empty.rs | 4 use futures_io::{AsyncBufRead, AsyncRead};
54 impl AsyncBufRead for Empty {
|
| D | buf_writer.rs | 3 use futures_io::{AsyncBufRead, AsyncRead, AsyncSeek, AsyncWrite, IoSlice, SeekFrom};
139 impl<W: AsyncBufRead> AsyncBufRead for BufWriter<W> {
|
| /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,
92 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 | 5 use crate::io::AsyncBufRead;
11 pub trait AsyncBufReadExt: AsyncBufRead {
259 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 | 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};
102 impl<R: AsyncBufRead> AsyncBufRead for Take<R> {
|
| D | empty.rs | 1 use crate::io::{AsyncBufRead, AsyncRead, ReadBuf};
60 impl AsyncBufRead for Empty {
|
| D | buf_writer.rs | 2 use crate::io::{AsyncBufRead, AsyncRead, AsyncWrite, ReadBuf};
155 impl<W: AsyncWrite + AsyncBufRead> AsyncBufRead for BufWriter<W> {
|
| /external/rust/crates/futures-io/src/ |
| D | lib.rs | 266 pub trait AsyncBufRead: AsyncRead { trait
523 impl<T: ?Sized + AsyncBufRead + Unpin> AsyncBufRead for Box<T> {
527 impl<T: ?Sized + AsyncBufRead + Unpin> AsyncBufRead for &mut T { impl
531 impl<P> AsyncBufRead for Pin<P>
534 P::Target: AsyncBufRead,
561 impl AsyncBufRead for &[u8] { impl
|
| /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()
|
| D | io_buf_reader.rs | 36 use futures::io::{AsyncRead,AsyncBufRead};
64 impl AsyncBufRead for MaybePending<'_> {
128 use futures::io::{AsyncSeekExt, AsyncBufRead, BufReader, Cursor, SeekFrom}; in test_buffered_reader_seek()
148 use futures::io::{AsyncSeekExt, AsyncBufRead, AllowStdIo, BufReader, SeekFrom}; in test_buffered_reader_seek_underflow()
294 use futures::io::{AsyncBufRead, AsyncSeek, AsyncSeekExt, AsyncRead, BufReader, in maybe_pending_seek()
320 impl AsyncBufRead for MaybePendingSeek<'_> { in maybe_pending_seek()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | lines.rs | 6 use tokio::io::{AsyncBufRead, Lines};
39 impl<R: AsyncBufRead> Stream for LinesStream<R> {
|
| D | split.rs | 6 use tokio::io::{AsyncBufRead, Split};
39 impl<R: AsyncBufRead> Stream for SplitStream<R> {
|