| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | async_read.rs | 41 fn poll_read( in poll_read() method
50 fn poll_read( in poll_read() method
55 Pin::new(&mut **self).poll_read(cx, buf) in poll_read()
61 fn poll_read( in poll_read() method
66 Pin::new(&mut **self).poll_read(cx, buf) in poll_read()
76 fn poll_read( in poll_read() function
81 self.get_mut().as_mut().poll_read(cx, buf) in poll_read()
210 fn poll_read( in poll_read() method
|
| H A D | read_task.rs | 65 match Pin::new(&mut reader).poll_read(cx, &mut buf) { in poll()
115 let poll = Pin::new(&mut reader).poll_read(cx, &mut read_buf); in poll_read_to_end()
255 let _ = match Pin::new(&mut reader).poll_read(cx, &mut this.buf) { in poll()
|
| H A D | stdin.rs | 46 fn poll_read( in poll_read() method
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/ |
| H A D | pty.rs | 179 fn poll_read( in poll_read() method
184 self.0.poll_read(cx, buf) in poll_read()
229 fn poll_read( in poll_read() method
234 self.0 .0.poll_read(cx, buf) in poll_read()
288 fn poll_read( in poll_read() method
293 self.0 .0.poll_read(cx, buf) in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | mix.rs | 33 fn poll_read( in poll_read() function
39 MixStream::Http(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
40 MixStream::Https(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
|
| H A D | wrapper.rs | 49 match stream.poll_read(cx, &mut buf)? { in read()
|
| H A D | c_ssl_stream.rs | 93 fn poll_read( in poll_read() function
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| H A D | mod.rs | 131 fn poll_read( in poll_read() function
160 Pin::new(&mut this.reader).poll_read(cx, buf) in poll_read()
233 ylong_runtime::futures::poll_fn(|cx| Pin::new(&mut uploader).poll_read(cx, &mut buf)) in upload()
248 ylong_runtime::futures::poll_fn(|cx| Pin::new(&mut multi_uploader).poll_read(cx, &mut buf)) in upload()
325 ylong_runtime::futures::poll_fn(|cx| Pin::new(&mut uploader).poll_read(cx, &mut buf)) in upload_and_show_progress()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | request.rs | 358 fn poll_read( in poll_read() method
368 return Pin::new(slice).poll_read(cx, buf); in poll_read()
372 BodyKind::Stream(ref mut stream) => Pin::new(stream).poll_read(cx, buf), in poll_read()
373 BodyKind::Multipart(ref mut multipart) => Pin::new(multipart).poll_read(cx, buf), in poll_read()
481 poll_fn(|cx| Pin::new(request.body_mut()).poll_read(cx, &mut read_buf)) in ut_client_request_builder_body()
|
| H A D | http_body.rs | 239 match Pin::new(&mut io).poll_read(cx, &mut read_buf) { in poll_read_io()
358 match Pin::new(&mut io).poll_read(cx, &mut read_buf) { in poll_read_io()
454 match Pin::new(&mut io).poll_read(cx, &mut read_buf) { in data()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | data_ref.rs | 39 pub(crate) fn poll_read( in poll_read() method
52 match data.poll_read(cx, &mut read_buf) { in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | stream.rs | 42 fn poll_read( in poll_read() function
47 Pin::new(&mut self.stream).poll_read(cx, buf) in poll_read()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | multipart.rs | 192 fn poll_read( in poll_read() method
208 return match Pin::new(status).poll_read(cx, buf) { in poll_read()
421 match stream.as_mut().poll_read(cx, buf) { in poll_read_curr()
457 fn poll_read( in poll_read() method
|
| H A D | mod.rs | 131 fn poll_read( in poll_read() function
158 match Pin::new(&mut this.reader).poll_read(cx, buf) { in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | split.rs | 30 fn poll_read( in poll_read() method
35 self.0.source.poll_read(cx, buf) in poll_read()
76 fn poll_read( in poll_read() method
81 self.0.source.poll_read(cx, buf) in poll_read()
|
| H A D | stream.rs | 599 fn poll_read( in poll_read() method
604 self.source.poll_read(cx, buf) in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| H A D | async_buf_reader.rs | 181 fn poll_read( in poll_read() method
189 return unsafe { Pin::new_unchecked(&mut this.inner).poll_read(cx, buf) }; in poll_read()
206 poll_ready!(Pin::new_unchecked(&mut this.inner).poll_read(cx, &mut read_buf))?; in poll_fill_buf()
|
| H A D | async_buf_writer.rs | 308 fn poll_read( in poll_read() method
314 unsafe { Pin::new_unchecked(&mut this.inner).poll_read(cx, buf) } in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | simple.rs | 205 fn poll_read( in poll_read() method
226 match Pin::new(status).poll_read(cx, buf) { in poll_read()
465 let result = unsafe { Pin::new_unchecked(stream).poll_read(cx, buf) }; in poll_read_curr()
483 fn poll_read( in poll_read() method
743 poll_fn(|cx| Pin::new(&mut mp).poll_read(cx, &mut read_buf)) in multipart_poll_data()
794 poll_fn(|cx| Pin::new(&mut mp).poll_read(cx, &mut read_buf)) in multipart_poll_data_stream()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | child.rs | 372 fn poll_read( in poll_read() method
377 Pin::new(&mut self.inner).poll_read(ctx, buf) in poll_read()
382 fn poll_read( in poll_read() method
387 Pin::new(&mut self.inner).poll_read(ctx, buf) in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/ |
| H A D | split.rs | 71 fn poll_read( in poll_read() method
77 guard.stream().poll_read(cx, buf) in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | child.rs | 170 fn poll_read( in poll_read() method
175 self.inner.poll_read(cx, buf) in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | stream.rs | 338 fn poll_read( in poll_read() method
343 self.source.poll_read(cx, buf) in poll_read()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http1.rs | 281 fn poll_read( in poll_read() method
286 Pin::new(self.raw_mut()).poll_read(cx, buf) in poll_read()
|
| /ohos5.0/base/request/request/services/src/task/ |
| H A D | upload.rs | 51 fn poll_read( in poll_read() method
73 match Pin::new(file).poll_read(cx, &mut read_buf) { in poll_read()
96 match Pin::new(file).poll_read(cx, buf) { in poll_read()
|