Searched refs:poll_recv (Results 1 – 14 of 14) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | mod.rs | 293 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() method
294 self.channel.poll_recv(cx) in poll_recv()
320 poll_fn(|cx| self.channel.poll_recv(cx)).await in recv()
|
| H A D | queue.rs | 219 pub(crate) fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() method
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | mod.rs | 412 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() method
413 self.channel.poll_recv(cx) in poll_recv()
440 poll_fn(|cx| self.channel.poll_recv(cx)).await in recv()
|
| H A D | array.rs | 168 pub(crate) fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() method
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/ |
| H A D | mod.rs | 147 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<()> { in poll_recv() method
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | input.rs | 192 match self.req_rx.poll_recv(cx) { in poll_recv_frame()
198 match self.req_rx.poll_recv(cx) { in poll_recv_frame()
|
| H A D | manager.rs | 73 match manager.resp_rx.poll_recv(cx) { in poll()
169 match self.req_rx.poll_recv(cx) { in poll_recv_request()
188 match self.req_rx.poll_recv(cx) { in poll_recv_request()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 578 pub(crate) fn poll_recv( in poll_recv() method
584 match receiver.poll_recv(cx) { in poll_recv()
596 match receiver.poll_recv(cx) { in poll_recv()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | child.rs | 68 let signal_pending = self.signal.poll_recv(cx).is_pending(); in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | signal.rs | 98 poll_fn(|cx| stream.poll_recv(cx)).await; in sdv_signal_poll_recv_test()
|
| H A D | udp_test.rs | 295 ylong_runtime::futures::poll_fn(|cx| connected_receiver.poll_recv(cx, &mut read)) in sdv_udp_send_recv_poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | mod.rs | 461 poll_fn(|cx| signal.poll_recv(cx)).await; in ut_signal_recv_and_poll_recv()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 1168 pub fn poll_recv(&self, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>) -> Poll<io::Result<()>> { in poll_recv() method
1611 poll_fn(|cx| connected_receiver.poll_recv(cx, &mut read)) in ut_send_recv_poll()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 363 .poll_recv(cx) in poll_read()
|