| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| H A 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()
183 cx: &mut Context<'_>, in poll_read()
184 buf: &mut ReadBuf<'_>, in poll_read()
223 cx: &mut Context<'_>, in poll_seek()
254 cx: &mut Context<'_>, in poll_write()
263 cx: &mut Context<'_>, in poll_write_vectored()
[all …]
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | mod.rs | 106 pub fn console(reader: R) -> Uploader<R, Console> { in console()
133 cx: &mut Context<'_>, in poll_read()
134 buf: &mut ReadBuf<'_>, in poll_read()
175 fn from(value: Uploader<R, U>) -> Self { in from()
181 fn as_ref(&self) -> &R { in as_ref()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A 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()
101 cx: &mut Context<'_>, in poll_read_to_end()
232 pub(crate) fn new(reader: &'a mut R, buf: &'a mut [u8]) -> ReadExactTask<'a, R> { in new() argument
255 let _ = match Pin::new(&mut reader).poll_read(cx, &mut this.buf) { in poll() localVariable
294 mut reader: &mut R, in poll_read_until()
297 cx: &mut Context<'_>, 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()
[all …]
|
| H A D | async_read.rs | 43 cx: &mut Context<'_>, in poll_read()
44 buf: &mut ReadBuf<'_>, in poll_read()
52 cx: &mut Context<'_>, in poll_read()
53 buf: &mut ReadBuf<'_>, in poll_read()
63 cx: &mut Context<'_>, in poll_read()
64 buf: &mut ReadBuf<'_>, in poll_read()
78 cx: &mut Context<'_>, in poll_read()
79 buf: &mut ReadBuf<'_>, in poll_read()
212 _cx: &mut Context<'_>, in poll_read()
213 buf: &mut ReadBuf<'_>, in poll_read()
[all …]
|
| H A D | async_write.rs | 42 cx: &mut Context<'_>, in poll_write()
52 cx: &mut Context<'_>, in poll_write_vectored()
53 bufs: &[IoSlice<'_>], in poll_write_vectored()
153 cx: &mut Context<'_>, in poll_write()
161 cx: &mut Context<'_>, in poll_write_vectored()
162 bufs: &[IoSlice<'_>], in poll_write_vectored()
274 fn flush(&mut self) -> FlushTask<'_, Self> in flush()
290 fn shutdown(&mut self) -> ShutdownTask<'_, Self> in shutdown()
328 impl<R: AsyncWrite + ?Sized> AsyncWriteExt for R {} implementation
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A 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()
325 let _ = entry.in_done.replace(false); in poll_join_next() localVariable
352 pub(crate) fn new(set: &'a mut JoinSet<R>) -> Builder<'a, R> { in new() argument
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | c_ssl_stream.rs | 29 fn with_context<F, R>(self: Pin<&mut Self>, ctx: &mut Context<'_>, f: F) -> R in with_context()
31 F: FnOnce(&mut ssl::SslStream<Wrapper<S>>) -> R, in with_context()
95 ctx: &mut Context<'_>, in poll_read()
96 buf: &mut ReadBuf<'_>, in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| H A D | mod.rs | 106 pub fn console(reader: R) -> Uploader<R, Console> { in console()
133 cx: &mut Context<'_>, in poll_read()
134 buf: &mut ReadBuf<'_>, in poll_read()
274 _cx: &mut Context<'_>, in upload_op_cov()
307 _cx: &mut Context<'_>, in upload_and_show_progress()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | async_source.rs | 80 F: FnMut() -> io::Result<R>, in async_process()
248 let _ = self.handle.io_deregister(&mut io); in drop() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | blocking_pool.rs | 96 let _ = handle.1.join(); in shutdown() localVariable
194 pub(crate) fn spawn_blocking<T, R>(&self, builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking()
|
| /ohos5.0/foundation/multimedia/camera_framework/frameworks/js/camera_napi/demo/hvigor/ |
| H A D | hvigor-wrapper.js | 16 …_process"),r=require("crypto"),n="undefined"!=typeof globalThis?globalThis:"undefined"!=typeof win… class
|
| /ohos5.0/foundation/distributeddatamgr/pasteboard/services/dialog/PasteboardDialog/hvigor/ |
| H A D | hvigor-wrapper.js | 15 …_process"),u=require("process"),o=require("tty"),i=require("util"),s=require("url"),c=require("con… variable
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/application/hvigor/ |
| H A D | hvigor-wrapper.js | 15 …_process"),u=require("process"),o=require("tty"),i=require("util"),s=require("url"),c=require("con… function
|
| /ohos5.0/base/useriam/face_auth/ui/Settings_FaceAuth/hvigor/ |
| H A D | hvigor-wrapper.js | 16 …_process"),u=require("process"),o=require("tty"),i=require("util"),s=require("url"),c=require("con… function
|