| /external/rust/crates/tokio/tests/ |
| D | time_timeout.rs | 14 let mut fut = task::spawn(timeout_at(Instant::now(), async {})); in simultaneous_deadline_future_completion() localVariable
24 let mut fut = task::spawn(timeout_at(Instant::now() - ms(1000), async {})); in completed_future_past_deadline() localVariable
38 let mut fut = task::spawn(timeout_at(Instant::now() + ms(100), rx)); in future_and_deadline_in_future() localVariable
62 let mut fut = task::spawn(timeout(ms(100), rx)); in future_and_timeout_in_future() localVariable
89 let mut fut = task::spawn(timeout(duration_max, rx)); in very_large_timeout() localVariable
112 let mut fut = task::spawn(timeout_at(Instant::now(), pending::<()>())); in deadline_now_elapses() localVariable
126 let mut fut = task::spawn(timeout_at(Instant::now() + ms(300), pending::<()>())); in deadline_future_elapses() localVariable
142 let fut = timeout(ms(1), async { in timeout_is_not_exhausted_by_future() localVariable
|
| D | macros_join.rs | 74 let fut = async { in join_size() localVariable
80 let fut = async { in join_size() localVariable
132 let fut = |x, poll_order: Arc<std::sync::Mutex<Vec<i32>>>| async move { in a_different_future_is_polled_first_every_time_poll_fn_is_polled() localVariable
|
| D | macros_try_join.rs | 96 let fut = async { in join_size() localVariable
102 let fut = async { in join_size() localVariable
161 let fut = |x, poll_order: Arc<std::sync::Mutex<Vec<i32>>>| async move { in a_different_future_is_polled_first_every_time_poll_fn_is_polled() localVariable
|
| D | macros_select.rs | 215 let fut = async { in struct_size() localVariable
225 let fut = async { in struct_size() localVariable
237 let fut = async { in struct_size() localVariable
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_collect.rs | 46 let mut fut = task::spawn(rx.collect::<Vec<i32>>()); in collect_vec_items() localVariable
68 let mut fut = task::spawn(rx.collect::<String>()); in collect_string_items() localVariable
90 let mut fut = task::spawn(rx.collect::<String>()); in collect_str_items() localVariable
112 let mut fut = task::spawn(rx.collect::<Result<String, &str>>()); in collect_results_ok() localVariable
134 let mut fut = task::spawn(rx.collect::<Result<String, &str>>()); in collect_results_err() localVariable
|
| /external/rust/crates/futures/tests/ |
| D | test_macro.rs | 3 let fut = async { true }; in it_works() localVariable
6 let fut = async { false }; in it_works() localVariable
13 let fut = async { false }; in it_is_being_run() localVariable
|
| D | async_await_macros.rs | 27 let fut = async { in join() localVariable
166 let fut = async { in select_size() localVariable
174 let fut = async { in select_size() localVariable
224 let fut = async { in select_on_non_unpin_size() localVariable
352 let fut = async { in join_size() localVariable
358 let fut = async { in join_size() localVariable
369 let fut = async { in try_join_size() localVariable
375 let fut = async { in try_join_size() localVariable
|
| D | stream_select_next_some.rs | 40 let mut fut = future::ready(1).pending_once(); in select() localVariable
69 let mut fut = future::ready(1).pending_once(); in futures_util_select() localVariable
|
| D | future_basic_combinators.rs | 11 let fut = future::ready(1) in basic_future_combinators() localVariable
47 let fut = future::ready(Ok(1)) in basic_try_future_combinators() localVariable
|
| D | future_shared.rs | 229 let fut = futures::future::poll_fn(|cx| { in shared_future_that_wakes_itself_until_pending_is_returned() localVariable
247 let fut = futures::future::poll_fn::<i8, _>(|_cx| panic!("test")).shared(); in panic_while_poll() localVariable
265 let fut = futures::future::ready(1).shared(); in poll_while_panic() localVariable
|
| /external/python/cpython3/Modules/ |
| D | _asynciomodule.c | 196 get_future_loop(PyObject *fut) in get_future_loop()
393 future_is_alive(FutureObj *fut) in future_is_alive()
400 future_ensure_alive(FutureObj *fut) in future_ensure_alive()
411 #define ENSURE_FUTURE_ALIVE(fut) \ argument
421 future_schedule_callbacks(FutureObj *fut) in future_schedule_callbacks()
477 future_init(FutureObj *fut, PyObject *loop) in future_init()
535 future_set_result(FutureObj *fut, PyObject *res) in future_set_result()
558 future_set_exception(FutureObj *fut, PyObject *exc) in future_set_exception()
620 future_set_cancelled_error(FutureObj *fut) in future_set_cancelled_error()
630 future_get_result(FutureObj *fut, PyObject **result) in future_get_result()
[all …]
|
| /external/libcxx/test/std/thread/futures/futures.async/ |
| D | async_race.38682.pass.cpp | 47 std::future<int> fut = std::async(std::launch::async, worker, v); in main() local
56 std::future<int&> fut = std::async(std::launch::async, worker_ref, std::ref(i)); in main() local
65 std::future<void> fut = std::async(std::launch::async, worker_void); in main() local
|
| /external/cronet/buildtools/third_party/libc++/trunk/test/std/thread/futures/futures.async/ |
| D | async_race.38682.pass.cpp | 41 std::future<int> fut = std::async(std::launch::async, worker, v); in main() local
50 std::future<int&> fut = std::async(std::launch::async, worker_ref, std::ref(i)); in main() local
59 std::future<void> fut = std::async(std::launch::async, worker_void); in main() local
|
| /external/rust/crates/tokio/src/macros/ |
| D | try_join.rs | 169 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
193 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
|
| D | join.rs | 123 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
145 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
|
| D | select.rs | 514 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
|
| /external/rust/crates/tokio-util/tests/ |
| D | reusable_box.rs | 23 let fut = async move { 10 }; in test_different_futures() localVariable
71 let fut = ZeroSizedFuture {}; in test_zero_sized() localVariable
|
| D | poll_semaphore.rs | 12 let fut = futures::future::poll_fn(move |cx| sem.poll_acquire(cx)); in semaphore_poll() localVariable
20 let fut = futures::future::poll_fn(move |cx| sem.poll_acquire_many(cx, permits)); in semaphore_poll_many() localVariable
|
| /external/python/cpython3/Lib/asyncio/ |
| D | selector_events.py | 370 def _sock_read_done(self, fd, fut, handle=None): argument
374 def _sock_recv(self, fut, sock, n): argument
411 def _sock_recv_into(self, fut, sock, buf): argument
459 def _sock_sendall(self, fut, sock, view, pos): argument
501 def _sock_connect(self, fut, sock, address): argument
522 def _sock_write_done(self, fd, fut, handle=None): argument
526 def _sock_connect_cb(self, fut, sock, address): argument
560 def _sock_accept(self, fut, sock): argument
|
| D | tasks.py | 392 async def wait_for(fut, timeout): argument
507 async def _cancel_and_wait(fut, loop): argument
720 def _done_callback(fut): argument
|
| D | futures.py | 296 def _get_loop(fut): argument
308 def _set_result_unless_cancelled(fut, result): argument
|
| /external/rust/crates/async-trait/tests/executor/ |
| D | mod.rs | 30 let fut = unsafe { Pin::new_unchecked(&mut fut) }; in block_on_simple() localVariable
|
| /external/rust/crates/tokio/src/signal/ |
| D | reusable_box.rs | 164 let fut = async move { 10 }; in test_different_futures() localVariable
212 let fut = ZeroSizedFuture {}; in test_zero_sized() localVariable
|
| /external/nanohttpd/websocket/src/test/java/fi/iki/elonen/samples/echo/ |
| D | SimpleEchoSocket.java | 87 Future<Void> fut; in onConnect() local
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | wait_for_handle.rs | 279 let fut = wait_on_unsignaled_event(async_evt); in test_unsignaled_event() localVariable
300 let fut = wait_on_signaled_event(async_evt); in test_signaled_event() localVariable
|