| /external/rust/crates/tokio-util/tests/ |
| D | mpsc.rs | 1 use futures::future::poll_fn;
13 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in simple()
18 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in simple()
35 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in repeated_poll_reserve()
50 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in abort_send()
55 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in abort_send()
119 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_before_reserve()
131 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_after_pending_reserve()
137 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_after_pending_reserve()
144 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_after_pending_reserve()
[all …]
|
| D | poll_semaphore.rs | 12 let fut = futures::future::poll_fn(move |cx| sem.poll_acquire(cx)); in semaphore_poll()
20 let fut = futures::future::poll_fn(move |cx| sem.poll_acquire_many(cx, permits)); in semaphore_poll_many()
|
| /external/rust/crates/tokio/tests/ |
| D | udp.rs | 4 use futures::future::poll_fn;
38 poll_fn(|cx| sender.poll_send(cx, MSG)).await?; in send_recv_poll()
42 poll_fn(|cx| receiver.poll_recv(cx, &mut read)).await?; in send_recv_poll()
70 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_recv_from_poll()
74 let addr = poll_fn(|cx| receiver.poll_recv_from(cx, &mut read)).await?; in send_to_recv_from_poll()
87 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_peek_from()
115 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_peek_from_poll()
119 let addr = poll_fn(|cx| receiver.poll_peek_from(cx, &mut read)).await?; in send_to_peek_from_poll()
126 poll_fn(|cx| receiver.poll_peek_from(cx, &mut read)).await?; in send_to_peek_from_poll()
132 poll_fn(|cx| receiver.poll_recv_from(cx, &mut read)).await?; in send_to_peek_from_poll()
[all …]
|
| D | uds_datagram.rs | 5 use futures::future::poll_fn;
152 poll_fn(|cx| sender.poll_send_to(cx, msg, &receiver_path)).await?; in send_to_recv_from_poll()
156 let addr = poll_fn(|cx| receiver.poll_recv_from(cx, &mut read)).await?; in send_to_recv_from_poll()
176 poll_fn(|cx| sender.poll_send(cx, msg)).await?; in send_recv_poll()
180 poll_fn(|cx| receiver.poll_recv(cx, &mut read)).await?; in send_recv_poll()
342 poll_fn(|cx| client.poll_send_ready(cx)).await?; in poll_ready()
355 poll_fn(|cx| server.poll_recv_ready(cx)).await?; in poll_ready()
|
| D | uds_stream.rs | 12 use futures::future::{poll_fn, try_join};
206 assert_ok!(poll_fn(|cx| $stream.poll_read_ready(cx)).await);
212 poll_fn(|cx| {
222 assert_ok!(poll_fn(|cx| $stream.poll_write_ready(cx)).await);
228 poll_fn(|cx| {
398 poll_fn(|cx| { in epollhup()
|
| D | tcp_stream.rs | 14 use futures::future::poll_fn;
181 assert_ok!(poll_fn(|cx| $stream.poll_read_ready(cx)).await);
187 poll_fn(|cx| {
197 assert_ok!(poll_fn(|cx| $stream.poll_write_ready(cx)).await);
203 poll_fn(|cx| {
|
| D | io_async_fd.rs | 406 assert_pending!(poll!(futures::future::poll_fn(|cx| afd_a_2 in poll_fns()
411 let _ = futures::future::poll_fn(|cx| afd_a_2.as_ref().poll_read_ready(cx)).await; in poll_fns()
420 assert_pending!(poll!(futures::future::poll_fn(|cx| afd_a_2 in poll_fns()
425 let _ = futures::future::poll_fn(|cx| afd_a_2.as_ref().poll_write_ready(cx)).await; in poll_fns()
536 futures::future::poll_fn(|cx| fd.poll_read_ready(cx)).await in poll_readable()
540 futures::future::poll_fn(|cx| fd.poll_write_ready(cx)).await in poll_writable()
|
| /external/rust/crates/tokio/src/future/ |
| D | mod.rs | 8 mod poll_fn; module
9 pub use poll_fn::poll_fn;
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_atomic_waker.rs | 3 use futures::future::poll_fn;
35 block_on(poll_fn(move |cx| { in basic_notification()
90 block_on(poll_fn(move |cx| { in test_panicky_waker()
|
| D | loom_notify.rs | 106 use crate::future::poll_fn; in notify_drop()
118 block_on(poll_fn(|cx| { in notify_drop()
|
| D | loom_oneshot.rs | 3 use futures::future::poll_fn;
32 let ready = block_on(poll_fn(|cx| match Pin::new(&mut rx).poll(cx) { in changing_rx_task()
|
| /external/rust/crates/futures-util/src/future/ |
| D | mod.rs | 68 mod poll_fn; module
69 pub use self::poll_fn::{poll_fn, PollFn};
|
| /external/rust/crates/futures-channel/tests/ |
| D | oneshot.rs | 3 use futures::future::{poll_fn, FutureExt};
13 let f = poll_fn(|cx| { in smoke_poll()
73 block_on(poll_fn(|cx| { in close()
|
| D | channel.rs | 3 use futures::future::poll_fn;
35 let f = poll_fn(|cx| rx.poll_next_unpin(cx)); in drop_sender()
|
| /external/rust/crates/tokio/src/signal/ |
| D | mod.rs | 87 use crate::future::poll_fn; in recv()
88 poll_fn(|cx| self.poll_recv(cx)).await in recv()
|
| /external/rust/crates/futures/tests/ |
| D | task_atomic_waker.rs | 2 use futures::future::poll_fn;
23 block_on(poll_fn(move |cx| { in basic()
|
| /external/rust/crates/tokio/src/time/ |
| D | interval.rs | 1 use crate::future::poll_fn;
438 || poll_fn(|cx| self.poll_tick(cx)), in tick()
445 let instant = poll_fn(|cx| self.poll_tick(cx)); in tick()
|
| /external/rust/crates/futures-util/src/stream/ |
| D | mod.rs | 88 mod poll_fn; module
89 pub use self::poll_fn::{poll_fn, PollFn};
|
| /external/rust/crates/tokio/src/macros/ |
| D | join.rs | 70 use $crate::macros::support::{maybe_done, poll_fn, Future, Pin};
95 poll_fn(move |cx| {
|
| D | try_join.rs | 116 use $crate::macros::support::{maybe_done, poll_fn, Future, Pin};
141 poll_fn(move |cx| {
|
| /external/rust/crates/tokio/src/io/util/ |
| D | split.rs | 62 use crate::future::poll_fn; in next_segment()
64 poll_fn(|cx| Pin::new(&mut *self).poll_next_segment(cx)).await in next_segment()
|
| D | lines.rs | 70 use crate::future::poll_fn; in next_line()
72 poll_fn(|cx| Pin::new(&mut *self).poll_next_line(cx)).await in next_line()
|
| /external/rust/crates/futures-executor/tests/ |
| D | local_pool.rs | 3 use futures::future::{self, lazy, poll_fn, Future};
183 Box::pin(poll_fn(move |ctx| { in try_run_one_returns_on_no_progress()
219 Box::pin(poll_fn(move |_| { in try_run_one_runs_sub_futures()
271 Box::pin(poll_fn(move |_| { in run_until_stalled_runs_spawned_sub_futures()
412 let future = future::poll_fn(move |cx| { in park_unpark_independence()
|
| /external/rust/crates/combine/src/stream/ |
| D | decoder.rs | 164 crate::future_ext::poll_fn(|cx| self.buffer.poll_extend_buf(cx, reader.as_mut())) in __before_parse_tokio_02()
183 crate::future_ext::poll_fn(|cx| self.buffer.poll_extend_buf(cx, reader.as_mut())) in __before_parse_tokio_03()
202 crate::future_ext::poll_fn(|cx| self.buffer.poll_extend_buf(cx, reader.as_mut())) in __before_parse_tokio()
|
| /external/rust/crates/tokio/src/runtime/time/tests/ |
| D | mod.rs | 57 block_on(futures::future::poll_fn(|cx| { in single_timer()
127 block_on(futures::future::poll_fn(|cx| { in change_waker()
167 block_on(futures::future::poll_fn(|cx| { in reset_future()
|