| /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
23 let mut fut = task::spawn(timeout_at(Instant::now() - ms(1000), async {})); in completed_future_past_deadline() localVariable
37 let mut fut = task::spawn(timeout_at(Instant::now() + ms(100), rx)); in future_and_deadline_in_future() localVariable
61 let mut fut = task::spawn(timeout(ms(100), rx)); in future_and_timeout_in_future() localVariable
88 let mut fut = task::spawn(timeout(duration_max, rx)); in very_large_timeout() localVariable
111 let mut fut = task::spawn(timeout_at(Instant::now(), pending::<()>())); in deadline_now_elapses() localVariable
125 let mut fut = task::spawn(timeout_at(Instant::now() + ms(300), pending::<()>())); in deadline_future_elapses() localVariable
|
| D | macros_join.rs | 60 let fut = async { in join_size() localVariable
66 let fut = async { in join_size() localVariable
|
| D | macros_try_join.rs | 85 let fut = async { in join_size() localVariable
91 let fut = async { in join_size() localVariable
|
| D | macros_select.rs | 203 let fut = async { in struct_size() localVariable
213 let fut = async { in struct_size() localVariable
225 let fut = async { in struct_size() localVariable
|
| D | time_interval.rs | 50 let fut = interval.tick(); in poll_next() 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 | async_await_macros.rs | 25 let fut = async { in join() localVariable
191 let fut = async { in select_size() localVariable
199 let fut = async { in select_size() localVariable
265 let fut = async { in select_on_non_unpin_size() localVariable
380 let fut = async { in join_size() localVariable
386 let fut = async { in join_size() localVariable
399 let fut = async { in try_join_size() localVariable
405 let fut = async { in try_join_size() localVariable
|
| D | stream_select_next_some.rs | 42 let mut fut = future::ready(1).pending_once(); in select() localVariable
75 let mut fut = future::ready(1).pending_once(); in futures_util_select() localVariable
|
| D | basic_combinators.rs | 11 let fut = future::ready(1) in basic_future_combinators() localVariable
43 let fut = future::ready(Ok(1)) in basic_try_future_combinators() localVariable
|
| /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/llvm-project/libcxx/test/std/thread/futures/futures.async/ |
| D | async_race.38682.pass.cpp | 46 std::future<int> fut = std::async(std::launch::async, worker, v); in main() local
55 std::future<int&> fut = std::async(std::launch::async, worker_ref, std::ref(i)); in main() local
64 std::future<void> fut = std::async(std::launch::async, worker_void); in main() local
|
| /external/python/cpython3/Modules/ |
| D | _asynciomodule.c | 202 get_future_loop(PyObject *fut) in get_future_loop()
392 future_is_alive(FutureObj *fut) in future_is_alive()
399 future_ensure_alive(FutureObj *fut) in future_ensure_alive()
410 #define ENSURE_FUTURE_ALIVE(fut) \ argument
420 future_schedule_callbacks(FutureObj *fut) in future_schedule_callbacks()
476 future_init(FutureObj *fut, PyObject *loop) in future_init()
534 future_set_result(FutureObj *fut, PyObject *res) in future_set_result()
557 future_set_exception(FutureObj *fut, PyObject *exc) in future_set_exception()
619 future_set_cancelled_error(FutureObj *fut) in future_set_cancelled_error()
629 future_get_result(FutureObj *fut, PyObject **result) in future_get_result()
[all …]
|
| /external/rust/crates/tokio/src/macros/ |
| D | join.rs | 83 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
100 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
|
| D | try_join.rs | 90 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
109 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
|
| D | select.rs | 452 let mut fut = unsafe { Pin::new_unchecked(fut) }; localVariable
|
| /external/rust/crates/flate2/tests/ |
| D | async-reader.rs | 67 let fut = read_to_end(AssertAsync(GzDecoder::new(BadReader::new(f))), Vec::new()); in test_gz_asyncread() localVariable
83 let fut = read_to_end( in test_multi_gz_asyncread() localVariable
|
| /external/python/cpython3/Lib/asyncio/ |
| D | selector_events.py | 375 def _sock_read_done(self, fd, fut, handle=None): argument
379 def _sock_recv(self, fut, sock, n): argument
416 def _sock_recv_into(self, fut, sock, buf): argument
464 def _sock_sendall(self, fut, sock, view, pos): argument
504 def _sock_connect(self, fut, sock, address): argument
525 def _sock_write_done(self, fd, fut, handle=None): argument
529 def _sock_connect_cb(self, fut, sock, address): argument
563 def _sock_accept(self, fut, sock): argument
|
| D | tasks.py | 421 async def wait_for(fut, timeout, *, loop=None): argument
542 async def _cancel_and_wait(fut, loop): argument
761 def _done_callback(fut): argument
|
| D | futures.py | 296 def _get_loop(fut): argument
308 def _set_result_unless_cancelled(fut, result): argument
|
| D | proactor_events.py | 271 def _loop_reading(self, fut=None): argument
437 def _pipe_closed(self, fut): argument
504 def _loop_writing(self, fut=None): argument
537 def _loop_reading(self, fut=None): 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/rust/crates/tokio/src/sync/tests/ |
| D | loom_oneshot.rs | 78 let fut = self.get_mut().tx.closed(); in poll() localVariable
|
| /external/rust/crates/tokio-test/src/ |
| D | task.rs | 74 let fut = self.future.as_mut(); in enter() localVariable
96 let fut = self.future.as_mut(); in poll() localVariable
|