| /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
98 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
230 pub(crate) fn new(reader: &'a mut R, buf: &'a mut [u8]) -> ReadExactTask<'a, R> { in new() argument
280 pub(crate) fn new(reader: &'a mut R, delim: u8, buf: &'a mut Vec<u8>) -> ReadUtilTask<'a, R> { in new() argument
292 mut reader: &mut R, in poll_read_until()
348 pub(crate) fn new(reader: &'a mut R, buf: &'a mut String) -> ReadLineTask<'a, R> { in new() argument
390 pub(crate) fn new(reader: R, delim: u8) -> SplitTask<R> { in new()
434 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
159 pub fn console(self) -> UploaderBuilder<WantsConfig<R, Console>> { in console()
211 pub fn build(self) -> Uploader<R, T> { in build()
|
| D | mod.rs | 105 pub fn console(reader: R) -> Uploader<R, Console> { in console()
179 fn as_ref(&self) -> &R { in as_ref()
|
| /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/fs/ |
| D | mod.rs | 36 T: FnOnce() -> io::Result<R>, in async_op()
|
| /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 | 73 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| D | spawn.rs | 21 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking()
|
| D | lib.rs | 83 pub fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | async_source.rs | 104 F: FnMut() -> io::Result<R>, in async_process()
|
| /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_io/src/sys/windows/ |
| D | net.rs | 97 F: FnOnce(&T) -> io::Result<R>, in try_io()
|
| /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()
|