Searched refs:AsyncBufReader (Results 1 - 6 of 6) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A D	async_buf_reader.rs	25 /// The `AsyncBufReader<R>` struct adds buffering to any reader that implements 30 /// When the `AsyncBufReader<R>` is dropped, the contents inside its buffer will 31 /// be discarded. Creating multiple instances of `AsyncBufReader<R>` on the same 33 pub struct AsyncBufReader<R> { structure names 40 impl<R: AsyncRead> AsyncBufReader<R> { impls 41 /// Creates a new `AsyncBufReader<R>` with a default buffer capacity. 51 /// use ylong_runtime::io::AsyncBufReader; 53 /// let reader = AsyncBufReader::new(f); 57 pub fn new(inner: R) -> AsyncBufReader<R> { in new() 58 AsyncBufReader in new() 84 impl<R> AsyncBufReader<R> { global() impls [all...]
H A D	mod.rs	17 pub use async_buf_reader::AsyncBufReader;
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A D	async_buf_read.rs	16 use ylong_runtime::io::{AsyncBufReadExt, AsyncBufReader, AsyncReadExt, AsyncWriteExt}; 19 /// SDV test cases for AsyncBufReader `read_util` 25 /// 3. The server wraps the TcpStream inside a AsyncBufReader 36 let mut buf_reader = AsyncBufReader::new(stream); in sdv_buf_reader_read_until() 63 /// SDV test cases for AsyncBufReader `read_line` 69 /// 3. The server wraps the TcpStream inside a AsyncBufReader 80 let mut buf_reader = AsyncBufReader::new(stream); in sdv_buf_reader_read_line() 105 /// SDV test cases for AsyncBufReader `split` 111 /// 3. The server wraps the TcpStream inside a AsyncBufReader 121 let buf_reader = AsyncBufReader in sdv_buf_reader_split() [all...]
H A D	async_read.rs	18 use ylong_runtime::io::{AsyncBufReader, AsyncReadExt, AsyncWriteExt}; 53 /// SDV for AsyncBufReader::read_line. 58 /// 3. The server wraps the TcpStream inside a AsyncBufReader 67 let mut buf_reader = AsyncBufReader::new(stream); in sdv_buf_reader_read_to_string()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A D	mod.rs	36 pub use buffered::{AsyncBufReader, AsyncBufWriter};
H A D	read_task.rs	485 use crate::io::AsyncBufReader; 491 /// 2. Create a AsyncBufReader. 506 let mut reader = AsyncBufReader::new(f); in ut_io_string_result()

Completed in 4 milliseconds

Indexes created Thu Nov 07 10:32:03 CST 2024