| /external/python/cpython3/Lib/test/ |
| D | test_coroutines.py | 42 def run_async(coro): function
542 self.assertEqual(run_async(f), ([], 10))
556 run_async(foo())
659 self.assertEqual(run_async(bar()), ([], 'spam'))
978 run_async(foo())
984 run_async(foo())
990 self.assertEqual(run_async(foo()), ([1, 2, 3], None))
1000 self.assertEqual(run_async(foo()), ([], 42))
1013 run_async(foo())
1023 self.assertEqual(run_async(foo()), ([52], None))
[all …]
|
| D | test_collections.py | 1289 def run_async(coro): function
1302 self.assertIs(run_async(mgen.asend(None)), run_async(mgen.__anext__()))
1303 self.assertEqual(2, run_async(mgen.asend(2)))
1304 self.assertIsNone(run_async(mgen.aclose()))
1306 run_async(mgen.athrow(ValueError))
1313 run_async(FailOnClose().aclose())
1320 run_async(IgnoreGeneratorExit().aclose())
|
| /external/pytorch/test/lazy/ |
| D | test_step_closures.py | 38 torch._lazy.add_step_closure(closure, run_async=True)
70 torch._lazy.add_step_closure(closure1, run_async=True)
80 torch._lazy.add_step_closure(closure2, run_async=True)
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | test_ticket_crypter.cc | 73 void TestTicketCrypter::SetRunCallbacksAsync(bool run_async) { in SetRunCallbacksAsync() argument
74 run_async_ = run_async; in SetRunCallbacksAsync()
|
| D | test_ticket_crypter.h | 27 void SetRunCallbacksAsync(bool run_async);
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | test_ticket_crypter.cc | 73 void TestTicketCrypter::SetRunCallbacksAsync(bool run_async) { in SetRunCallbacksAsync() argument
74 run_async_ = run_async; in SetRunCallbacksAsync()
|
| D | test_ticket_crypter.h | 27 void SetRunCallbacksAsync(bool run_async);
|
| /external/tensorflow/tensorflow/python/eager/ |
| D | run_eager_op_as_function_test.py | 243 run_async = test_util.TestDelta("pflr_runsync", "async")
251 assert run_async.Get() == 0
262 run_async = test_util.TestDelta("pflr_runsync", "async")
271 assert run_async.Get() == 0
|
| /external/pytorch/torch/_lazy/ |
| D | closure.py | 86 def add_step_closure(closure, args=(), run_async=False): argument
108 closures_type = "async_step_closures" if run_async else "step_closures"
|
| /external/python/cpython3/Lib/test/test_unittest/testmock/ |
| D | testthreadingmock.py | 33 def run_async(self, func, /, *args, delay=0, **kwargs): member in TestThreadingMock
115 self.run_async(waitable_mock.method_1, delay=VERY_SHORT_TIMEOUT)
137 self.run_async(waitable_mock, delay=VERY_SHORT_TIMEOUT)
|
| /external/pigweed/pw_cli/py/pw_cli/ |
| D | process.py | 147 async def run_async( function
213 return asyncio.run(run_async(program, *args, **kwargs))
|
| /external/python/bumble/apps/ |
| D | auracast.py | 604 def run_async(async_command: Coroutine) -> None: function
646 run_async(run_scan(filter_duplicates, sync_timeout, transport))
673 run_async(run_assist(broadcast_name, source_id, command, transport, address))
682 run_async(run_pair(transport, address))
|
| D | console.py | 284 async def run_async(self, device_config, transport): member in ConsoleApp
304 await self.ui.run_async()
1208 asyncio.run(app.run_async(device_config, transport))
|
| /external/pytorch/torch/csrc/jit/api/ |
| D | method.h | 42 c10::intrusive_ptr<c10::ivalue::Future> run_async(
|
| D | module.cpp | 216 c10::intrusive_ptr<c10::ivalue::Future> Method::run_async( in run_async() function in torch::jit::Method
|
| /external/crosvm/devices/src/virtio/video/ |
| D | worker.rs | 355 pub async fn run_async( in run_async() method
|
| /external/pigweed/pw_unit_test/py/pw_unit_test/ |
| D | test_runner.py | 209 process = await pw_cli.process.run_async(
|
| /external/pytorch/test/cpp/jit/ |
| D | test_module_api.cpp | 76 auto future = method.run_async(stack, kwargs, launcher); in TEST()
|
| /external/pigweed/pw_console/py/pw_console/ |
| D | console_app.py | 1275 await self.application.run_async(set_exception_handler=True)
|