| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | read_task.rs | 47 pub(crate) fn new(reader: &'a mut R, buf: &'a mut [u8]) -> ReadTask<'a, R> { in new() argument
87 pub(crate) fn new(reader: &'a mut R, buf: &'a mut Vec<u8>) -> ReadToEndTask<'a, R> { in new() argument
99 mut reader: &mut R, in poll_read_to_end()
158 pub(crate) fn new(reader: &'a mut R, dst: &'a mut String) -> ReadToStringTask<'a, R> { in new() argument
232 pub(crate) fn new(reader: &'a mut R, buf: &'a mut [u8]) -> ReadExactTask<'a, R> { in new() argument
282 pub(crate) fn new(reader: &'a mut R, delim: u8, buf: &'a mut Vec<u8>) -> ReadUtilTask<'a, R> { in new() argument
294 mut reader: &mut R, in poll_read_until()
350 pub(crate) fn new(reader: &'a mut R, buf: &'a mut String) -> ReadLineTask<'a, R> { in new() argument
392 pub(crate) fn new(reader: R, delim: u8) -> SplitTask<R> { in new()
436 pub(crate) fn new(reader: R) -> LinesTask<R> { in new()
|
| D | async_buf_read.rs | 167 impl<R: AsyncBufRead + ?Sized> AsyncBufReadExt for R {} implementation
|
| D | async_read.rs | 223 impl<R: AsyncRead + ?Sized> AsyncReadExt for R {} implementation
|
| D | async_write.rs | 328 impl<R: AsyncWrite + ?Sized> AsyncWriteExt for R {} implementation
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| D | builder.rs | 62 pub fn reader<R: AsyncRead>(self, reader: R) -> UploaderBuilder<WantsOperator<R>> { in reader() method
134 pub fn operator<T: UploadOperator>(self, operator: T) -> UploaderBuilder<WantsConfig<R, T>> { in operator() method
158 pub fn console(self) -> UploaderBuilder<WantsConfig<R, Console>> { in console()
209 pub fn build(self) -> Uploader<R, T> { in build()
|
| D | mod.rs | 106 pub fn console(reader: R) -> Uploader<R, Console> { in console()
|
| /commonlibrary/rust/ylong_json/src/ |
| D | states.rs | 76 deserializer: &mut Deserializer<R>, in check_recursion()
87 deserializer: &mut Deserializer<R>, in start_parsing()
199 deserializer: &mut Deserializer<R>, in parse_string()
208 deserializer: &mut Deserializer<R>, in parse_string()
224 deserializer: &mut Deserializer<R>, in parse_string_inner()
271 deserializer: &mut Deserializer<R>, in parse_escape_character()
298 deserializer: &mut Deserializer<R>, in parse_unicode()
320 deserializer: &mut Deserializer<R>, in parse_unicode()
353 deserializer: &mut Deserializer<R>, in parse_number()
485 deserializer: &mut Deserializer<R>, in read_error_char()
[all …]
|
| D | deserializer.rs | 104 pub fn from_reader<R, T>(reader: R) -> Result<T, Error> in from_reader()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| D | async_buf_reader.rs | 57 pub fn new(inner: R) -> AsyncBufReader<R> { in new()
74 pub fn with_capacity(capacity: usize, inner: R) -> AsyncBufReader<R> { in with_capacity()
100 pub fn get_ref(&self) -> &R { in get_ref()
119 pub fn get_mut(&mut self) -> &mut R { in get_mut()
169 pub fn into_inner(self) -> R { in into_inner()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | join_set.rs | 120 fn wake_by_ref(entry: &Arc<JoinEntry<R>>) { in wake_by_ref()
209 pub async fn join_next(&mut self) -> Option<Result<R, ScheduleError>> { in join_next()
280 pub fn build_task(&mut self) -> Builder<'_, R> { in build_task() argument
284 fn poll_join_next(&mut self, cx: &mut Context<'_>) -> Poll<Option<Result<R, ScheduleError>>> { in poll_join_next()
352 pub(crate) fn new(set: &'a mut JoinSet<R>) -> Builder<'a, R> { in new() argument
|
| D | builder.rs | 72 pub fn spawn_blocking<T, R>(&self, task: T) -> JoinHandle<R> in spawn_blocking()
|
| D | join_handle.rs | 56 pub(crate) fn new(raw: RawTask) -> JoinHandle<R> { in new()
|
| D | mod.rs | 151 pub fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | mod.rs | 36 T: FnOnce() -> io::Result<R>, in async_op()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| D | spawn.rs | 60 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | async_source.rs | 80 F: FnMut() -> io::Result<R>, in async_process()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| D | net.rs | 79 F: FnOnce(&T) -> io::Result<R>, in try_io()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| D | c_ssl_stream.rs | 31 F: FnOnce(&mut ssl::SslStream<Wrapper<S>>) -> R, in with_context()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | blocking_pool.rs | 194 pub(crate) fn spawn_blocking<T, R>(&self, builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking()
|