| /external/rust/crates/futures-channel/benches/ |
| D | sync_mpsc.rs | 30 assert_eq!(Poll::Pending, rx.poll_next_unpin(&mut cx)); in unbounded_1_tx()
35 assert_eq!(Poll::Ready(Some(i)), rx.poll_next_unpin(&mut cx)); in unbounded_1_tx()
52 assert_eq!(Poll::Pending, rx.poll_next_unpin(&mut cx)); in unbounded_100_tx()
56 assert_eq!(Poll::Ready(Some(i)), rx.poll_next_unpin(&mut cx)); in unbounded_100_tx()
71 assert_eq!(Poll::Ready(Some(i)), rx.poll_next_unpin(&mut cx)); in unbounded_uncontended()
111 assert_eq!(Poll::Ready(Some(i + 1)), tx.poll_next_unpin(&mut cx)); in bounded_1_tx()
112 assert_eq!(Poll::Pending, tx.poll_next_unpin(&mut cx)); in bounded_1_tx()
113 assert_eq!(Poll::Ready(Some(i + 1)), rx.poll_next_unpin(&mut cx)); in bounded_1_tx()
136 assert_eq!(Poll::Ready(Some(i + 1)), x.poll_next_unpin(&mut cx)); in bounded_100_tx()
138 assert_eq!(Poll::Pending, x.poll_next_unpin(&mut cx)); in bounded_100_tx()
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | ready_queue.rs | 26 assert!(!queue.poll_next_unpin(cx).is_ready()); in basic_usage()
30 assert_eq!(Poll::Ready(Some(Ok("hello"))), queue.poll_next_unpin(cx)); in basic_usage()
31 assert!(!queue.poll_next_unpin(cx).is_ready()); in basic_usage()
36 assert_eq!(Poll::Ready(Some(Ok("world"))), queue.poll_next_unpin(cx)); in basic_usage()
37 assert_eq!(Poll::Ready(Some(Ok("world2"))), queue.poll_next_unpin(cx)); in basic_usage()
38 assert_eq!(Poll::Ready(None), queue.poll_next_unpin(cx)); in basic_usage()
60 assert!(!queue.poll_next_unpin(cx).is_ready()); in resolving_errors()
64 assert_eq!(Poll::Ready(Some(Err(oneshot::Canceled))), queue.poll_next_unpin(cx)); in resolving_errors()
65 assert!(!queue.poll_next_unpin(cx).is_ready()); in resolving_errors()
70 assert_eq!(Poll::Ready(Some(Err(oneshot::Canceled))), queue.poll_next_unpin(cx)); in resolving_errors()
[all …]
|
| D | futures_ordered.rs | 15 assert!(stream.poll_next_unpin(&mut noop_context()).is_pending()); in works_1()
46 assert!(stream.poll_next_unpin(&mut cx).is_ready()); in works_2()
47 assert!(stream.poll_next_unpin(&mut cx).is_pending()); in works_2()
49 assert!(stream.poll_next_unpin(&mut cx).is_ready()); in works_2()
88 assert!(stream.poll_next_unpin(cx).is_pending()); in queue_never_unblocked()
92 assert!(stream.poll_next_unpin(cx).is_pending()); in queue_never_unblocked()
94 assert!(stream.poll_next_unpin(cx).is_pending()); in queue_never_unblocked()
95 assert!(stream.poll_next_unpin(cx).is_pending()); in queue_never_unblocked()
|
| D | futures_unordered.rs | 19 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(None)); in is_terminated()
34 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(Some(1))); in is_terminated()
36 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(None)); in is_terminated()
89 assert_eq!(stream.poll_next_unpin(&mut cx), Poll::Ready(Some(Ok(9)))); in works_2()
91 assert_eq!(stream.poll_next_unpin(&mut cx), Poll::Ready(Some(Ok(30)))); in works_2()
92 assert_eq!(stream.poll_next_unpin(&mut cx), Poll::Ready(None)); in works_2()
133 assert!(stream.poll_next_unpin(cx).is_pending()); in finished_future()
138 assert!(stream.poll_next_unpin(cx).is_ready()); in finished_future()
139 assert!(stream.poll_next_unpin(cx).is_pending()); in finished_future()
140 assert!(stream.poll_next_unpin(cx).is_pending()); in finished_future()
[all …]
|
| D | try_stream.rs | 15 assert_eq!(Poll::Ready(None), s.poll_next_unpin(cx)); in try_filter_map_after_err()
26 assert_eq!(Poll::Ready(None), s.poll_next_unpin(cx)); in try_skip_while_after_err()
37 assert_eq!(Poll::Ready(None), s.poll_next_unpin(cx)); in try_take_while_after_err()
|
| D | stream_select_all.rs | 12 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(None)); in is_terminated()
25 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(Some(1))); in is_terminated()
27 assert_eq!(tasks.poll_next_unpin(&mut cx), Poll::Ready(None)); in is_terminated()
|
| D | sink.rs | 12 match s.poll_next_unpin(&mut panic_context()) { in sassert_next()
|
| /external/rust/crates/futures-util/benches/ |
| D | futures_unordered.rs | 36 if let Poll::Ready(None) = rxs.poll_next_unpin(cx) { in oneshots()
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | next.rs | 35 self.stream.poll_next_unpin(cx) in poll()
|
| D | select_next_some.rs | 34 if let Some(item) = ready!(self.stream.poll_next_unpin(cx)) { in poll()
|
| D | into_future.rs | 88 ready!(s.poll_next_unpin(cx)) in poll()
|
| D | buffered.rs | 80 let res = this.in_progress_queue.poll_next_unpin(cx); in poll_next()
|
| D | buffer_unordered.rs | 82 match this.in_progress_queue.poll_next_unpin(cx) { in poll_next()
|
| D | for_each_concurrent.rs | 101 match this.futures.poll_next_unpin(cx) { in poll()
|
| D | mod.rs | 1411 fn poll_next_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> in poll_next_unpin() method
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc-close.rs | 199 if let Poll::Ready(v) = rx.poll_next_unpin(cx) { in stress_try_send_as_receiver_closes()
207 match self.command_rx.poll_next_unpin(cx) { in stress_try_send_as_receiver_closes()
|
| D | channel.rs | 38 rx.poll_next_unpin(cx) in drop_sender()
|
| D | mpsc.rs | 113 assert_eq!(rx.poll_next_unpin(cx), Poll::Ready(None)); in recv_close_gets_none()
129 assert_eq!(rx.poll_next_unpin(cx), Poll::Ready(None)); in tx_close_gets_none()
294 match rx.poll_next_unpin(&mut noop_context()) { in stress_receiver_multi_task_bounded_hard()
|
| /external/rust/crates/futures-util/src/stream/ |
| D | select_all.rs | 83 match ready!(self.inner.poll_next_unpin(cx)) { in poll_next()
|
| D | futures_ordered.rs | 172 match ready!(this.in_progress_queue.poll_next_unpin(cx)) { in poll_next()
|
| /external/rust/crates/futures-util/src/stream/try_stream/ |
| D | try_buffered.rs | 66 match this.in_progress_queue.poll_next_unpin(cx) { in poll_next()
|
| D | try_buffer_unordered.rs | 63 match this.in_progress_queue.poll_next_unpin(cx) { in poll_next()
|
| D | try_for_each_concurrent.rs | 108 match this.futures.poll_next_unpin(cx) { in poll()
|
| /external/rust/crates/futures-executor/src/ |
| D | local_pool.rs | 299 self.pool.poll_next_unpin(cx) in poll_pool_once()
|