| /external/rust/crates/tokio/src/signal/ |
| D | unix.rs | 434 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<()>> { in poll_recv() method
435 self.inner.poll_recv(cx) in poll_recv()
441 fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<()>>; in poll_recv() method
445 fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<()>> { in poll_recv() method
446 self.poll_recv(cx) in poll_recv()
|
| D | windows.rs | 225 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<()>> { in poll_recv() method
226 self.inner.inner.poll_recv(cx) in poll_recv()
297 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<()>> { in poll_recv() method
298 self.inner.inner.poll_recv(cx) in poll_recv()
|
| D | mod.rs | 88 poll_fn(|cx| self.poll_recv(cx)).await in recv()
91 fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<()>> { in poll_recv() method
|
| /external/rust/crates/tokio/tests/support/ |
| D | mpsc_stream.rs | 14 Pin::into_inner(self).recv.poll_recv(cx) in poll_next()
32 Pin::into_inner(self).recv.poll_recv(cx) in poll_next()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | signal_windows.rs | 32 self.inner.poll_recv(cx) in poll_next()
74 self.inner.poll_recv(cx) in poll_next()
|
| D | signal_unix.rs | 32 self.inner.poll_recv(cx) in poll_next()
|
| D | mpsc_unbounded.rs | 39 self.inner.poll_recv(cx) in poll_next()
|
| D | mpsc_bounded.rs | 45 self.inner.poll_recv(cx) in poll_next()
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | unbounded.rs | 122 poll_fn(|cx| self.poll_recv(cx)).await in recv()
178 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<T>> { in poll_recv() method
|
| D | bounded.rs | 282 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<T>> { in poll_recv() method
|
| /external/rust/crates/tokio/src/process/unix/ |
| D | reap.rs | 87 let registered_interest = self.signal.poll_recv(cx).is_pending(); in poll()
201 fn poll_recv(&mut self, _cx: &mut Context<'_>) -> Poll<Option<()>> { in poll_recv() method
|
| /external/rust/crates/tokio/src/sync/ |
| D | oneshot.rs | 697 ready!(inner.poll_recv(cx))? in poll()
725 fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() method
|
| /external/rust/crates/tokio/tests/ |
| D | uds_datagram.rs | 181 let _len = poll_fn(|cx| receiver.poll_recv(cx, &mut read)).await?; in send_recv_poll()
|
| D | udp.rs | 41 let _len = poll_fn(|cx| receiver.poll_recv(cx, &mut read)).await?; in send_recv_poll()
|
| /external/rust/crates/tokio/src/net/unix/datagram/ |
| D | socket.rs | 1029 pub fn poll_recv(&self, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>) -> Poll<io::Result<()>> { in poll_recv() method
|
| /external/rust/crates/tokio/src/net/ |
| D | udp.rs | 666 pub fn poll_recv(&self, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>) -> Poll<io::Result<()>> { in poll_recv() method
|
| /external/rust/crates/tokio/ |
| D | CHANGELOG.md | 135 - signal: make `Signal::poll_recv` method public ([#3383])
282 - sync: `poll_recv` fns to `mpsc::Receiver`, `mpsc::UnboundedReceiver` ([#3308]).
1110 - API docs for `signal::unix::Signal::{recv, poll_recv}` and `signal::windows::CtrlBreak::{recv, po…
|