| /external/rust/crates/futures/tests/ |
| D | mutex.rs | 9 assert!(mutex.lock().poll_unpin(&mut panic_context()).is_ready()); in mutex_acquire_uncontested()
22 let lock = mutex.lock().poll_unpin(&mut panic_context()); in mutex_wakes_waiters()
27 assert!(waiter.poll_unpin(&mut cx).is_pending()); in mutex_wakes_waiters()
33 assert!(waiter.poll_unpin(&mut panic_context()).is_ready()); in mutex_wakes_waiters()
|
| D | stream_select_next_some.rs | 16 assert_eq!(select_next_some.poll_unpin(&mut cx), Poll::Pending); in is_terminated()
25 assert_eq!(select_next_some.poll_unpin(&mut cx), Poll::Ready(1)); in is_terminated()
27 assert_eq!(select_next_some.poll_unpin(&mut cx), Poll::Pending); in is_terminated()
|
| D | fuse.rs | 10 assert!(future.poll_unpin(&mut cx).is_ready()); in fuse()
11 assert!(future.poll_unpin(&mut cx).is_pending()); in fuse()
|
| D | sink.rs | 341 assert!(task.poll_unpin(cx).is_pending()); in mpsc_blocking_start_send()
345 unwrap(task.poll_unpin(cx)); in mpsc_blocking_start_send()
379 assert!(task.poll_unpin(cx).is_pending()); in with_flush()
383 unwrap(task.poll_unpin(cx)); in with_flush()
477 assert!(task.poll_unpin(cx).is_pending()); in with_flush_propagate()
482 unwrap(sink.flush().poll_unpin(cx)); in with_flush_propagate()
559 assert!(task.poll_unpin(cx).is_pending()); in buffer()
563 unwrap(task.poll_unpin(cx)); in buffer()
604 assert!(task.poll_unpin(cx).is_pending()); in fanout_backpressure()
607 assert!(task.poll_unpin(cx).is_pending()); in fanout_backpressure()
[all …]
|
| D | abortable.rs | 27 assert_eq!(Poll::Pending, abortable_rx.poll_unpin(&mut cx)); in abortable_awakens()
31 assert_eq!(Poll::Ready(Err(Aborted)), abortable_rx.poll_unpin(&mut cx)); in abortable_awakens()
|
| D | io_read_to_string.rs | 35 if let Poll::Ready(x) = f.poll_unpin(&mut cx) { in interleave_pending()
|
| D | io_read_line.rs | 34 if let Poll::Ready(x) = f.poll_unpin(&mut cx) { in maybe_pending()
|
| D | io_read_until.rs | 34 if let Poll::Ready(x) = f.poll_unpin(&mut cx) { in maybe_pending()
|
| D | io_lines.rs | 11 if let Poll::Ready(x) = f.poll_unpin(&mut cx) { in run()
|
| D | stream.rs | 148 assert!(s.next().poll_unpin(&mut cx).is_pending()); in ready_chunks()
|
| D | io_buf_writer.rs | 53 if let Poll::Ready(x) = f.poll_unpin(&mut cx) { in run()
|
| D | io_buf_reader.rs | 25 if let Poll::Ready(x) = f.poll_unpin(&mut cx) { in run()
|
| D | futures_unordered.rs | 220 self.future.poll_unpin(cx).map(Some) in iter_cancel()
|
| /external/rust/crates/futures-util/src/future/ |
| D | select.rs | 99 match a.poll_unpin(cx) { in poll()
101 Poll::Pending => match b.poll_unpin(cx) { in poll()
|
| D | select_all.rs | 50 match f.poll_unpin(cx) { in poll()
|
| /external/rust/crates/tokio/src/process/unix/ |
| D | reap.rs | 224 assert!(grim.poll_unpin(&mut context).is_pending()); in reaper()
232 assert!(grim.poll_unpin(&mut context).is_pending()); in reaper()
239 if let Poll::Ready(r) = grim.poll_unpin(&mut context) { in reaper()
|
| /external/rust/crates/futures-util/src/async_await/ |
| D | poll.rs | 37 Poll::Ready(self.future.poll_unpin(cx)) in poll()
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc.rs | 601 assert_eq!(task.poll_unpin(&mut cx), Poll::Pending); in send_backpressure()
607 assert_eq!(task.poll_unpin(&mut cx), Poll::Ready(Ok(()))); in send_backpressure()
623 assert_eq!(task.poll_unpin(&mut cx), Poll::Pending); in send_backpressure_multi_senders()
629 assert_eq!(task.poll_unpin(&mut cx), Poll::Ready(Ok(()))); in send_backpressure_multi_senders()
|
| D | oneshot.rs | 72 match rx.poll_unpin(cx) { in close()
|
| /external/crosvm/cros_async/src/ |
| D | select.rs | 53 complete |= self.$Fut.poll_unpin(cx).is_ready();
|
| /external/rust/crates/tokio/src/process/ |
| D | mod.rs | 1360 let _ = guard.poll_unpin(&mut context); in no_kill_if_reaped()
1366 let _ = guard.poll_unpin(&mut context); in no_kill_if_reaped()
1372 let _ = guard.poll_unpin(&mut context); in no_kill_if_reaped()
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | remote_handle.rs | 61 match ready!(self.rx.poll_unpin(cx)) { in poll()
|
| D | mod.rs | 558 fn poll_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Self::Output> in poll_unpin() method
|
| /external/rust/crates/futures-macro/src/ |
| D | select.rs | 209 __futures_crate::Some(__futures_crate::future::FutureExt::poll_unpin( in select_inner()
|
| /external/rust/crates/futures-executor/src/ |
| D | thread_pool.rs | 326 let res = future.poll_unpin(&mut cx); in run()
|