| /external/rust/crates/tokio/tests/ |
| D | macros_select.rs | 10 async fn sync_one_lit_expr_comma() { in sync_one_lit_expr_comma()
12 foo = async { 1 } => foo, in sync_one_lit_expr_comma()
19 async fn nested_one() { in nested_one()
21 foo = async { 1 } => tokio::select! { in nested_one()
22 bar = async { foo } => bar, in nested_one()
30 async fn sync_one_lit_expr_no_comma() { in sync_one_lit_expr_no_comma()
32 foo = async { 1 } => foo in sync_one_lit_expr_no_comma()
39 async fn sync_one_lit_expr_block() { in sync_one_lit_expr_block()
41 foo = async { 1 } => { foo } in sync_one_lit_expr_block()
48 async fn sync_one_await() { in sync_one_await()
[all …]
|
| D | macros_try_join.rs | 6 async fn sync_one_lit_expr_comma() { in sync_one_lit_expr_comma()
7 let foo = tokio::try_join!(async { ok(1) },); in sync_one_lit_expr_comma()
13 async fn sync_one_lit_expr_no_comma() { in sync_one_lit_expr_no_comma()
14 let foo = tokio::try_join!(async { ok(1) }); in sync_one_lit_expr_no_comma()
20 async fn sync_two_lit_expr_comma() { in sync_two_lit_expr_comma()
21 let foo = tokio::try_join!(async { ok(1) }, async { ok(2) },); in sync_two_lit_expr_comma()
27 async fn sync_two_lit_expr_no_comma() { in sync_two_lit_expr_no_comma()
28 let foo = tokio::try_join!(async { ok(1) }, async { ok(2) }); in sync_two_lit_expr_no_comma()
34 async fn two_await() { in two_await()
39 task::spawn(async { tokio::try_join!(async { rx1.await }, async { rx2.await }) }); in two_await()
[all …]
|
| D | task_local_set.rs | 20 async fn local_basic_scheduler() { in local_basic_scheduler()
22 .run_until(async { in local_basic_scheduler()
23 task::spawn_local(async {}).await.unwrap(); in local_basic_scheduler()
29 async fn local_threadpool() { in local_threadpool()
37 .run_until(async { in local_threadpool()
39 task::spawn_local(async { in local_threadpool()
49 async fn localset_future_threadpool() { in localset_future_threadpool()
57 local.spawn_local(async move { in localset_future_threadpool()
64 async fn localset_future_timers() { in localset_future_timers()
69 local.spawn_local(async move { in localset_future_timers()
[all …]
|
| D | rt_common.rs | 78 rt.block_on(async {
90 let out = rt.block_on(async {
108 let out = rt.block_on(async {
111 tokio::spawn(async move {
125 let out = rt.block_on(async {
128 let handle = tokio::spawn(async move {
148 let out = rt.block_on(async {
152 tokio::spawn(async move {
156 tokio::spawn(async move {
175 let out = rt.block_on(async {
[all …]
|
| D | macros_join.rs | 6 async fn sync_one_lit_expr_comma() { in sync_one_lit_expr_comma()
7 let foo = tokio::join!(async { 1 },); in sync_one_lit_expr_comma()
13 async fn sync_one_lit_expr_no_comma() { in sync_one_lit_expr_no_comma()
14 let foo = tokio::join!(async { 1 }); in sync_one_lit_expr_no_comma()
20 async fn sync_two_lit_expr_comma() { in sync_two_lit_expr_comma()
21 let foo = tokio::join!(async { 1 }, async { 2 },); in sync_two_lit_expr_comma()
27 async fn sync_two_lit_expr_no_comma() { in sync_two_lit_expr_no_comma()
28 let foo = tokio::join!(async { 1 }, async { 2 }); in sync_two_lit_expr_no_comma()
34 async fn two_await() { in two_await()
38 let mut join = task::spawn(async { in two_await()
[all …]
|
| D | tcp_connect.rs | 11 async fn connect_v4() { in connect_v4()
18 tokio::spawn(async move { in connect_v4()
38 async fn connect_v6() { in connect_v6()
45 tokio::spawn(async move { in connect_v6()
65 async fn connect_addr_ip_string() { in connect_addr_ip_string()
70 let server = async { in connect_addr_ip_string()
74 let client = async { in connect_addr_ip_string()
82 async fn connect_addr_ip_str_slice() { in connect_addr_ip_str_slice()
87 let server = async { in connect_addr_ip_str_slice()
91 let client = async { in connect_addr_ip_str_slice()
[all …]
|
| D | task_blocking.rs | 15 async fn basic_blocking() { in basic_blocking()
19 tokio::spawn(async { in basic_blocking()
36 async fn block_in_blocking() { in block_in_blocking()
40 tokio::spawn(async { in block_in_blocking()
59 async fn block_in_block() { in block_in_block()
63 tokio::spawn(async { in block_in_block()
80 async fn no_block_in_basic_scheduler() { in no_block_in_basic_scheduler()
87 rt.block_on(async { in yes_block_in_threaded_block_on()
96 rt.block_on(async { in no_block_in_basic_block_on()
105 outer.block_on(async { in can_enter_basic_rt_from_within_block_in_place()
[all …]
|
| D | task_builder.rs | 10 async fn spawn_with_name() { in spawn_with_name()
13 .spawn(async { "task executed" }) in spawn_with_name()
20 async fn spawn_blocking_with_name() { in spawn_blocking_with_name()
30 async fn spawn_local_with_name() { in spawn_local_with_name()
33 .run_until(async move { in spawn_local_with_name()
36 .spawn_local(async move { unsend_data }) in spawn_local_with_name()
45 async fn spawn_without_name() { in spawn_without_name()
46 let result = Builder::new().spawn(async { "task executed" }).await; in spawn_without_name()
52 async fn spawn_blocking_without_name() { in spawn_blocking_without_name()
59 async fn spawn_local_without_name() { in spawn_local_without_name()
[all …]
|
| D | macros_test.rs | 4 async fn test_macro_can_be_used_via_use() { in test_macro_can_be_used_via_use()
5 tokio::spawn(async {}).await.unwrap(); in test_macro_can_be_used_via_use()
9 async fn test_macro_is_resilient_to_shadowing() { in test_macro_is_resilient_to_shadowing()
10 tokio::spawn(async {}).await.unwrap(); in test_macro_is_resilient_to_shadowing()
16 pub async fn unused_braces_main() { println!("hello") } in unused_braces_main()
19 async fn unused_braces_test() { assert_eq!(1 + 1, 2) } in unused_braces_test()
29 async fn f(self) {} in trait_method()
36 pub async fn issue_4175_main_1() -> ! { in issue_4175_main_1()
40 pub async fn issue_4175_main_2() -> std::io::Result<()> { in issue_4175_main_2()
45 pub async fn issue_4175_test() -> std::io::Result<()> { in issue_4175_test()
|
| /external/rust/crates/async-trait/tests/ |
| D | test.rs | 26 async fn selfvalue(self) in selfvalue()
32 async fn selfref(&self) {} in selfref()
34 async fn selfmut(&mut self) {} in selfmut()
36 async fn required() -> Self::Assoc; in required()
38 async fn elided_lifetime(_x: &str) {} in elided_lifetime()
40 async fn explicit_lifetime<'a>(_x: &'a str) {} in explicit_lifetime()
42 async fn generic_type_param<T: Send>(x: Box<T>) -> T { in generic_type_param()
46 async fn calls(&self) { in calls()
52 async fn calls_mut(&mut self) { in calls_mut()
63 async fn selfvalue(self) {} in selfvalue()
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_coroutines.py | 510 async def foo():
527 async def foo():
536 async def foo():
544 async def foo():
577 async def foo():
602 async def foo():
612 async def bar():
632 async def foo():
640 async def foo():
676 async def foo():
[all …]
|
| D | test_contextlib_async.py | 30 async def test_enter(self):
32 async def __aexit__(self, *args):
38 async with manager as context:
42 async def test_async_gen_propagates_generator_exit(self):
46 async def ctx():
49 async def gen():
50 async with ctx():
56 async with ctx():
57 async for val in gen():
72 async def __aenter__(self):
[all …]
|
| D | test_asyncgen.py | 43 async def iterate():
45 async for i in gen:
69 async def anext_impl():
178 async def gen():
190 async def gen():
219 async def gen():
229 async def gen():
250 async def gen():
259 async def gen():
278 async def async_gen():
[all …]
|
| /external/mockito/src/test/java/org/mockitousage/verification/ |
| D | VerificationWithAfterTest.java | 21 import org.mockitoutil.async.AsyncTesting;
42 private AsyncTesting async = new AsyncTesting(); field in VerificationWithAfterTest
46 async.cleanUp(); in tearDown()
52 async.runAfter(10, callMock); in should_verify_with_after()
53 async.runAfter(1000, callMock); in should_verify_with_after()
62 async.runAfter(10, callMock); in should_verify_with_after_and_fail()
63 async.runAfter(40, callMock); in should_verify_with_after_and_fail()
77 async.runAfter(10, callMock); in should_verify_with_time_x()
78 async.runAfter(50, callMock); in should_verify_with_time_x()
79 async.runAfter(600, callMock); in should_verify_with_time_x()
[all …]
|
| D | VerificationWithTimeoutTest.java | 20 import org.mockitoutil.async.AsyncTesting;
38 private AsyncTesting async; field in VerificationWithTimeoutTest
42 async = new AsyncTesting(); in setUp()
47 async.cleanUp(); in tearDown()
53 async.runAfter(50, callMock('c')); in should_verify_with_timeout()
54 async.runAfter(500, callMock('c')); in should_verify_with_timeout()
64 async.runAfter(200, callMock('c')); in should_verify_with_timeout_and_fail()
99 async.runAfter(50, callMock('c')); in should_verify_with_times_x()
100 async.runAfter(100, callMock('c')); in should_verify_with_times_x()
101 async.runAfter(600, callMock('c')); in should_verify_with_times_x()
[all …]
|
| /external/python/cpython3/Lib/unittest/test/ |
| D | test_async_case.py | 28 async def asyncSetUp(self):
33 async def test_func(self):
39 async def asyncTearDown(self):
52 async def on_cleanup1(self):
61 async def on_cleanup2(self):
87 async def asyncSetUp(self):
92 async def test_func(self):
95 async def asyncTearDown(self):
98 async def on_cleanup(self):
123 async def asyncSetUp(self):
[all …]
|
| /external/Reactive-Extensions/RxCpp/Ix/CPP/samples/SampleCppLinq/ |
| D | data.txt | 1 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22437888.0, '…
2 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22626304.0, '…
3 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22503424.0, '…
4 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22667264.0, '…
5 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22323200.0, '…
11 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22626304.0, '…
12 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22806528.0, '…
13 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22556672.0, '…
14 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22609920.0, '…
15 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22573056.0, '…
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | async_await_macros.rs | 14 let pending_once = async { pending!() }; in poll_and_pending()
15 block_on(async { in poll_and_pending()
27 let fut = async { in join()
32 block_on(async { in join()
48 block_on(async { in select()
66 block_on(async { in select_biased()
86 block_on(async { in select_streams()
130 block_on(async { in select_can_move_uncompleted_futures()
151 let res = block_on(async { in select_nested()
166 let fut = async { in select_size()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | AwaitTest.kt | 14 val d = async { in <lambda>()
19 val d2 = async { in <lambda>()
39 val d = async(start = CoroutineStart.LAZY) { in <lambda>()
43 val d2 = async(start = CoroutineStart.LAZY) { in <lambda>()
53 val d1 = async { 1L } in <lambda>()
54 val d2 = async { "" } in <lambda>()
55 val d3 = async { } in <lambda>()
65 val d = async { in <lambda>()
70 val d2 = async(NonCancellable) { in <lambda>()
75 val d3 = async { in <lambda>()
[all …]
|
| D | AsyncTest.kt | 17 val d = async { in <lambda>()
33 val d = async(start = CoroutineStart.UNDISPATCHED) { in testUndispatched()
46 val d = async<Unit> { in <lambda>()
57 val d = async(NonCancellable, start = CoroutineStart.ATOMIC) { in <lambda>()
74 val deferred = async(Job()) { in <lambda>()
86 val deferred = async(NonCancellable) { in <lambda>()
87 val decomposed = async(NonCancellable) { in <lambda>()
103 val deferred = async(NonCancellable) { in <lambda>()
105 val decomposed = async { // inherits parent job! in <lambda>()
127 val deferred = async(NonCancellable) { in <lambda>()
[all …]
|
| /external/curl/lib/ |
| D | asyn-ares.c | 221 static void destroy_async_data(struct Curl_async *async);
229 if(data->state.async.resolver) in Curl_resolver_cancel()
230 ares_cancel((ares_channel)data->state.async.resolver); in Curl_resolver_cancel()
231 destroy_async_data(&data->state.async); in Curl_resolver_cancel()
248 static void destroy_async_data(struct Curl_async *async) in destroy_async_data() argument
250 free(async->hostname); in destroy_async_data()
252 if(async->tdata) { in destroy_async_data()
253 struct thread_data *res = async->tdata; in destroy_async_data()
261 async->tdata = NULL; in destroy_async_data()
264 async->hostname = NULL; in destroy_async_data()
[all …]
|
| /external/rust/crates/async-trait/ |
| D | README.md | 4 …ge/github-dtolnay/async--trait-8da0cb?style=for-the-badge&labelColor=555555&logo=github" height="2…
5 …img.shields.io/crates/v/async-trait.svg?style=for-the-badge&color=fc8d62&logo=rust" height="20">](…
6 …async--trait-66c2a5?style=for-the-badge&labelColor=555555&logoColor=white&logo=data:image/svg+xml;…
7 …/github/workflow/status/dtolnay/async-trait/CI/master?style=for-the-badge" height="20">](https://g…
9 The initial round of stabilizations for the async/await language feature in Rust
10 1.39 did not include support for async fn in traits. Trying to include an async
15 async fn f() {}
20 error[E0706]: trait fns cannot be declared `async`
23 4 | async fn f() {}
27 This crate provides an attribute macro to make async fn in traits work.
[all …]
|
| /external/libchrome/third_party/jinja2/ |
| D | asyncfilters.py | 7 async def auto_to_seq(value):
10 async for item in value:
18 async def async_select_or_reject(args, kwargs, modfunc, lookup_attr):
22 async for item in auto_aiter(seq):
62 async def do_first(environment, seq):
70 async def do_groupby(environment, value, attribute):
78 async def do_join(eval_ctx, value, d=u'', attribute=None):
83 async def do_list(value):
88 async def do_reject(*args, **kwargs):
93 async def do_rejectattr(*args, **kwargs):
[all …]
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_locks.py | 24 async def test_repr(self):
33 async def test_lock(self):
49 async def test_lock_doesnt_accept_loop_parameter(self):
68 async def test_lock_by_with_statement(self):
93 async def test_acquire(self):
99 async def c1(result):
104 async def c2(result):
109 async def c3(result):
144 async def test_acquire_cancel(self):
154 async def test_cancel_race(self):
[all …]
|
| /external/python/jinja/src/jinja2/ |
| D | asyncsupport.py | 15 async def concat_async(async_gen):
18 async def collect():
19 async for event in async_gen:
26 async def generate_async(self, *args, **kwargs):
29 async for event in self.root_render_func(self.new_context(vars)):
52 async def render_async(self, *args, **kwargs):
77 async def async_call(self):
94 async def async_invoke(self, arguments, autoescape):
110 async def get_default_module_async(self):
127 async def make_module_async(self, vars=None, shared=False, locals=None):
[all …]
|