Searched refs:AsyncReadExt (Results 1 – 25 of 62) sorted by relevance
123
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | io_read_to_string.rs | 5 use tokio::io::AsyncReadExt;
25 match AsyncReadExt::read_to_string(&mut data.as_slice(), &mut s).await { in to_string_does_not_truncate_on_utf8_error()
42 match AsyncReadExt::read_to_string(&mut mock, &mut s).await { in to_string_does_not_truncate_on_io_error()
57 let len = AsyncReadExt::read_to_string(&mut data.as_slice(), &mut s) in to_string_appends()
|
| D | io_read_to_end.rs | 6 use tokio::io::{AsyncRead, AsyncReadExt, ReadBuf};
100 AsyncReadExt::read_to_end(&mut mock, &mut buf) in read_to_end_doesnt_grow_with_capacity()
120 AsyncReadExt::read_to_end(&mut mock, &mut buf) in read_to_end_grows_capacity_if_unfit()
|
| D | async_send_sync.rs | 607 async_assert_fn!(tokio::io::AsyncReadExt::read(&mut BoxAsyncRead, &mut [u8]): Send & Sync & !Unpin);
608 async_assert_fn!(tokio::io::AsyncReadExt::read_buf(&mut BoxAsyncRead, &mut Vec<u8>): Send & Sync & …
610 tokio::io::AsyncReadExt::read_exact(&mut BoxAsyncRead, &mut [u8]): Send & Sync & !Unpin
612 async_assert_fn!(tokio::io::AsyncReadExt::read_u8(&mut BoxAsyncRead): Send & Sync & !Unpin);
613 async_assert_fn!(tokio::io::AsyncReadExt::read_i8(&mut BoxAsyncRead): Send & Sync & !Unpin);
614 async_assert_fn!(tokio::io::AsyncReadExt::read_u16(&mut BoxAsyncRead): Send & Sync & !Unpin);
615 async_assert_fn!(tokio::io::AsyncReadExt::read_i16(&mut BoxAsyncRead): Send & Sync & !Unpin);
616 async_assert_fn!(tokio::io::AsyncReadExt::read_u32(&mut BoxAsyncRead): Send & Sync & !Unpin);
617 async_assert_fn!(tokio::io::AsyncReadExt::read_i32(&mut BoxAsyncRead): Send & Sync & !Unpin);
618 async_assert_fn!(tokio::io::AsyncReadExt::read_u64(&mut BoxAsyncRead): Send & Sync & !Unpin);
[all …]
|
| D | io_read_exact.rs | 4 use tokio::io::AsyncReadExt;
|
| D | io_repeat.rs | 4 use tokio::io::AsyncReadExt;
|
| D | io_chain.rs | 4 use tokio::io::AsyncReadExt;
|
| D | tcp_shutdown.rs | 5 use tokio::io::{self, AsyncReadExt, AsyncWriteExt};
|
| D | process_kill_on_drop.rs | 7 use tokio::io::AsyncReadExt;
|
| D | tcp_peek.rs | 5 use tokio::io::AsyncReadExt;
|
| D | uds_split.rs | 6 use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt};
|
| D | tcp_into_std.rs | 7 use tokio::io::{AsyncReadExt, AsyncWriteExt};
|
| D | tcp_echo.rs | 5 use tokio::io::{self, AsyncReadExt, AsyncWriteExt};
|
| D | tcp_split.rs | 9 use tokio::io::{AsyncReadExt, AsyncWriteExt};
|
| D | io_read.rs | 4 use tokio::io::{AsyncRead, AsyncReadExt, ReadBuf};
|
| D | duplex_stream.rs | 5 use tokio::io::{AsyncReadExt, AsyncWriteExt};
|
| D | io_take.rs | 6 use tokio::io::{self, AsyncRead, AsyncReadExt, ReadBuf};
|
| /external/rust/android-crates-io/crates/tokio/src/io/util/ |
| D | async_read_ext.rs | 62 pub trait AsyncReadExt: AsyncRead { trait
1430 impl<R: AsyncRead + ?Sized> AsyncReadExt for R {}
|
| D | mod.rs | 8 pub use async_read_ext::AsyncReadExt;
|
| /external/rust/android-crates-io/crates/futures/src/ |
| D | lib.rs | 118 pub use futures_util::{AsyncBufReadExt, AsyncReadExt, AsyncSeekExt, AsyncWriteExt};
252 AsyncBufReadExt as _, AsyncReadExt as _, AsyncSeekExt as _, AsyncWriteExt as _,
|
| /external/rust/android-crates-io/crates/tokio-util/src/io/ |
| D | sync_bridge.rs | 3 AsyncBufRead, AsyncBufReadExt, AsyncRead, AsyncReadExt, AsyncSeek, AsyncSeekExt, AsyncWrite,
40 self.rt.block_on(AsyncReadExt::read(src, buf)) in read()
|
| /external/rust/android-crates-io/crates/futures/tests/ |
| D | io_read_exact.rs | 2 use futures::io::AsyncReadExt;
|
| D | io_read_to_end.rs | 3 io::{self, AsyncRead, AsyncReadExt},
|
| D | io_read_to_string.rs | 3 use futures::io::{AsyncReadExt, Cursor};
|
| /external/rust/android-crates-io/crates/tokio-util/tests/ |
| D | io_stream_reader.rs | 4 use tokio::io::AsyncReadExt;
|
| D | compat.rs | 6 use futures_util::{AsyncReadExt, AsyncSeekExt, AsyncWriteExt};
|
123