| /external/rust/crates/tokio/src/io/util/ |
| D | mod.rs | 53 mod read_to_end;
56 pub(crate) use read_to_end::read_to_end;
91 mod read_to_end;
93 pub(crate) use read_to_end::read_to_end;
|
| D | async_read_ext.rs | 11 use crate::io::util::read_to_end::{read_to_end, ReadToEnd};
1021 fn read_to_end<'a>(&'a mut self, buf: &'a mut Vec<u8>) -> ReadToEnd<'a, Self>
1025 read_to_end(self, buf)
|
| /external/rust/crates/flate2/tests/ |
| D | empty-read.rs | 15 decoder.read_to_end(&mut decoded).unwrap(); in deflate_decoder_empty_read()
25 encoder.read_to_end(&mut encoded).unwrap(); in deflate_encoder_empty_read()
28 decoder.read_to_end(&mut decoded).unwrap(); in deflate_encoder_empty_read()
41 decoder.read_to_end(&mut decoded).unwrap(); in gzip_decoder_empty_read()
51 encoder.read_to_end(&mut encoded).unwrap(); in gzip_encoder_empty_read()
54 decoder.read_to_end(&mut decoded).unwrap(); in gzip_encoder_empty_read()
67 decoder.read_to_end(&mut decoded).unwrap(); in zlib_decoder_empty_read()
77 encoder.read_to_end(&mut encoded).unwrap(); in zlib_encoder_empty_read()
80 decoder.read_to_end(&mut decoded).unwrap(); in zlib_encoder_empty_read()
|
| D | async-reader.rs | 11 use tokio_io::io::read_to_end;
67 let fut = read_to_end(AssertAsync(GzDecoder::new(BadReader::new(f))), Vec::new()); in test_gz_asyncread()
73 .read_to_end(&mut expected) in test_gz_asyncread()
83 let fut = read_to_end( in test_multi_gz_asyncread()
92 .read_to_end(&mut expected) in test_multi_gz_asyncread()
|
| D | gunzip.rs | 17 .read_to_end(&mut expected) in test_extract_success()
47 .read_to_end(&mut expected) in test_extract_success_multi()
56 GzDecoder::new(f).read_to_end(&mut v)?; in extract_file()
65 MultiGzDecoder::new(f).read_to_end(&mut v)?; in extract_file_multi()
|
| /external/rust/crates/flate2/src/deflate/ |
| D | mod.rs | 27 r.read_to_end(&mut ret).unwrap(); in roundtrip()
39 r.read_to_end(&mut ret).unwrap(); in drop_writes()
63 r.read_to_end(&mut ret).unwrap(); in total_in()
74 r.read_to_end(&mut ret).unwrap(); in roundtrip2()
110 r.read_to_end(&mut a).unwrap(); in reset_reader()
112 r.read_to_end(&mut b).unwrap(); in reset_reader()
115 r.read_to_end(&mut c).unwrap(); in reset_reader()
129 r.read_to_end(&mut a).unwrap(); in reset_decoder()
131 r.read_to_end(&mut b).unwrap(); in reset_decoder()
134 r.read_to_end(&mut c).unwrap(); in reset_decoder()
[all …]
|
| /external/rust/crates/flate2/src/zlib/ |
| D | mod.rs | 28 r.read_to_end(&mut ret).unwrap(); in roundtrip()
40 r.read_to_end(&mut ret).unwrap(); in drop_writes()
64 r.read_to_end(&mut ret).unwrap(); in total_in()
74 r.read_to_end(&mut ret).unwrap(); in roundtrip2()
98 r.read_to_end(&mut a).unwrap(); in reset_decoder()
100 r.read_to_end(&mut b).unwrap(); in reset_decoder()
103 r.read_to_end(&mut c).unwrap(); in reset_decoder()
141 r.read_to_end(&mut v2).unwrap(); in qc_reader()
|
| /external/rust/crates/tokio/tests/ |
| D | io_read_to_end.rs | 10 async fn read_to_end() { in read_to_end() function
14 let n = assert_ok!(rd.read_to_end(&mut buf).await); in read_to_end()
76 test.read_to_end(&mut buf).await.unwrap(); in read_to_end_uninit()
|
| D | io_copy_bidirectional.rs | 76 b.read_to_end(&mut Vec::new()).await.unwrap(); in test_transfer_after_close()
104 b.read_to_end(&mut buf).await.unwrap(); in blocking_one_side_does_not_block_other()
|
| D | io_chain.rs | 14 assert_ok!(rd.read_to_end(&mut buf).await); in chain()
|
| D | uds_split.rs | 41 read.read_to_end(&mut output).await?; in send_recv_all()
|
| /external/rust/crates/flate2/src/gz/ |
| D | mod.rs | 297 r.read_to_end(&mut v).unwrap(); in roundtrip_big()
306 r.read_to_end(&mut res).unwrap(); in roundtrip_big2()
323 d.read_to_end(&mut res).unwrap(); in fields()
348 r.read_to_end(&mut v2).unwrap(); in qc_reader()
|
| /external/rust/crates/nix/test/sys/ |
| D | test_aio.rs | 333 let len = f.read_to_end(&mut rbuf).unwrap(); in test_write()
363 let len = f.read_to_end(&mut rbuf).unwrap(); in test_write_bytes()
421 let len = f.read_to_end(&mut rbuf).unwrap(); in test_write_from_pointer()
486 let len = f.read_to_end(&mut rbuf).unwrap(); in test_write_sigev_signal()
533 let len = f.read_to_end(&mut rbuf2).unwrap(); in test_liocb_listio_wait()
582 let len = f.read_to_end(&mut rbuf2).unwrap(); in test_liocb_listio_nowait()
641 let len = f.read_to_end(&mut rbuf2).unwrap(); in test_liocb_listio_signal()
|
| /external/rust/crates/futures-util/src/io/ |
| D | mod.rs | 110 mod read_to_end; module
111 pub use self::read_to_end::ReadToEnd;
290 fn read_to_end<'a>( in read_to_end() method
|
| D | allow_std.rs | 115 fn read_to_end(&mut self, buf: &mut Vec<u8>) -> io::Result<usize> { in read_to_end() function
116 self.0.read_to_end(buf) in read_to_end()
|
| /external/rust/crates/flate2/examples/ |
| D | deflateencoder-bufread.rs | 22 deflater.read_to_end(&mut buffer)?; in open_hello_world()
|
| D | gzencoder-bufread.rs | 22 gz.read_to_end(&mut buffer)?; in open_hello_world()
|
| D | zlibencoder-bufread.rs | 22 z.read_to_end(&mut buffer)?; in open_hello_world()
|
| /external/flatbuffers/tests/rust_usage_test/bin/ |
| D | monster_example.rs | 22 f.read_to_end(&mut buf).expect("file reading failed"); in main()
|
| /external/rust/crates/bytes/tests/ |
| D | test_reader.rs | 14 buf.reader().read_to_end(&mut buffer).unwrap(); in read()
|
| /external/rust/crates/nix/test/test_kmod/ |
| D | mod.rs | 91 f.read_to_end(&mut contents) in test_init_and_delete_module()
111 f.read_to_end(&mut contents) in test_init_and_delete_module_with_params()
|
| /external/rust/crates/zip/tests/ |
| D | zip_crypto.rs | 82 file.read_to_end(&mut data).unwrap(); in encrypted_file()
|
| /external/rust/crates/futures/tests/ |
| D | io_read_to_end.rs | 62 read.read_to_end(&mut vec.inner).await.unwrap(); in issue2310()
|
| /external/rust/crates/tokio/src/process/ |
| D | mod.rs | 1088 async fn read_to_end<A: AsyncRead + Unpin>(io: Option<A>) -> io::Result<Vec<u8>> { in wait_with_output() function
1091 crate::io::util::read_to_end(&mut io, &mut vec).await?; in wait_with_output()
1096 let stdout_fut = read_to_end(self.stdout.take()); in wait_with_output()
1097 let stderr_fut = read_to_end(self.stderr.take()); in wait_with_output()
|
| /external/rust/crates/csv/examples/ |
| D | tutorial-perf-core-01.rs | 65 if let Err(err) = io::stdin().read_to_end(&mut data) { in main()
|