| /external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/test/ |
| D | TaskTest.kt | 24 val deferred = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
29 val task = deferred.asTask() in <lambda>()
37 val deferred = async { in <lambda>() constant
42 val task = deferred.asTask() in <lambda>()
49 val deferred = GlobalScope.async { in testCancelledAsTask() constant
53 val task = deferred.asTask() in testCancelledAsTask()
64 val deferred = GlobalScope.async<Int> { in testThrowingAsTask() constant
68 val task = deferred.asTask() in testThrowingAsTask()
78 val deferred: Deferred<Int> = Tasks.call { in <lambda>() constant
82 assertFalse(deferred.isCompleted) in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | AsyncTest.kt | 74 val deferred = async(Job()) { in <lambda>() constant
80 deferred.join() in <lambda>()
86 val deferred = async(NonCancellable) { in <lambda>() constant
97 assertEquals(42, deferred.await()) in <lambda>()
103 val deferred = async(NonCancellable) { in <lambda>() constant
119 assertEquals(42, deferred.await()) in <lambda>()
127 val deferred = async(NonCancellable) { in <lambda>() constant
136 deferred.await()
142 val deferred = async(NonCancellable) { in <lambda>() constant
151 deferred.await()
[all …]
|
| D | DelayDurationTest.kt | 29 val deferred = async { in <lambda>() constant
38 deferred.await() in <lambda>()
44 val deferred = async { in <lambda>() constant
53 deferred.await() in <lambda>()
59 val deferred = async { in <lambda>() constant
67 require(deferred.isActive) in <lambda>()
68 deferred.cancel() in <lambda>()
70 deferred.await() in <lambda>()
|
| D | DelayTest.kt | 31 val deferred = async { in <lambda>() constant
39 deferred.await() in <lambda>()
45 val deferred = async { in <lambda>() constant
53 require(deferred.isActive) in <lambda>()
54 deferred.cancel() in <lambda>()
56 deferred.await() in <lambda>()
|
| D | AwaitCancellationTest.kt | 15 val deferred: Deferred<Nothing> = async { in <lambda>() constant
21 require(deferred.isActive) in <lambda>()
22 deferred.cancel() in <lambda>()
24 deferred.await() in <lambda>()
|
| /external/perfetto/src/ipc/ |
| D | deferred_unittest.cc | 37 Deferred<TestMessage> deferred; in TEST() local
39 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
52 deferred.Resolve(std::move(res)); in TEST()
56 EXPECT_DCHECK(deferred.Resolve(std::move(res))); in TEST()
57 EXPECT_DCHECK(deferred.Reject()); in TEST()
64 Deferred<TestMessage> deferred; in TEST() local
66 deferred.Bind([num_callbacks](AsyncResult<TestMessage> msg) { in TEST()
76 deferred.Reject(); in TEST()
77 EXPECT_DCHECK(deferred.Resolve(std::move(res))); in TEST()
78 EXPECT_DCHECK(deferred.Reject()); in TEST()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryTest.kt | 34 val deferred = createDeferred(3) in <lambda>() constant
47 nestedMethod(deferred, *traces.toTypedArray()) in <lambda>()
48 deferred.join() in <lambda>()
53 val deferred = async<Unit>(coroutineContext + NonCancellable) { in <lambda>() constant
57 deferred.join() in <lambda>()
70 nestedMethod(deferred, *stacktrace.toTypedArray()) in <lambda>()
73 private suspend fun nestedMethod(deferred: Deferred<*>, vararg traces: String) { in <lambda>()
74 oneMoreNestedMethod(deferred, *traces) in <lambda>()
78 private suspend fun oneMoreNestedMethod(deferred: Deferred<*>, vararg traces: String) { in <lambda>()
80 deferred.await() in <lambda>()
[all …]
|
| D | StackTraceRecoverySelectTest.kt | 39 val deferred = CompletableDeferred<Unit>() in <lambda>() constant
40 deferred.completeExceptionally(RecoverableTestException()) in <lambda>()
41 val result = runCatching { doSelectAwait(deferred) } in <lambda>()
45 private suspend fun doSelectAwait(deferred: Deferred<Unit>): Int { in doSelectAwait()
47 deferred.onAwait { in doSelectAwait()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | DebugProbesTest.kt | 19 val deferred = createDeferred() in <lambda>() constant
32 nestedMethod(deferred, traces) in <lambda>()
33 deferred.join() in <lambda>()
40 val deferred = createDeferred() in <lambda>() constant
62 nestedMethod(deferred, traces) in <lambda>()
63 deferred.join() in <lambda>()
71 val deferred = createDeferred() in <lambda>() constant
86 nestedMethod(deferred, traces) in <lambda>()
87 deferred.join() in <lambda>()
91 private suspend fun nestedMethod(deferred: Deferred<*>, traces: List<String>) { in nestedMethod()
[all …]
|
| D | CoroutinesDumpTest.kt | 18 val deferred = async(Dispatchers.Default) { in <lambda>() constant
23 val found = DebugProbes.dumpCoroutinesInfo().single { it.job === deferred } in <lambda>()
34 deferred.cancel() in <lambda>()
37 assertSame(deferred, found.job) in <lambda>()
42 val deferred = async(Dispatchers.IO) { in <lambda>() constant
53 …at kotlinx.coroutines.debug.CoroutinesDumpTest\$testRunningCoroutine\$1$deferred\$1.invokeSuspend(… in <lambda>()
66 deferred.cancel() in <lambda>()
73 val deferred = async(Dispatchers.IO) { in <lambda>() constant
96 deferred.cancel() in <lambda>()
103 val deferred = async(Dispatchers.IO) { in <lambda>() constant
[all …]
|
| D | SanitizedProbesTest.kt | 26 val deferred = createDeferred() in <lambda>() constant
44 nestedMethod(deferred, traces) in <lambda>()
45 deferred.join() in <lambda>()
50 val deferred = createActiveDeferred() in <lambda>() constant
75 deferred.cancelAndJoin() in <lambda>()
134 private suspend fun nestedMethod(deferred: Deferred<*>, traces: List<String>) { in nestedMethod()
135 oneMoreNestedMethod(deferred, traces) in nestedMethod()
139 private suspend fun oneMoreNestedMethod(deferred: Deferred<*>, traces: List<String>) { in oneMoreNestedMethod()
141 deferred.await() in oneMoreNestedMethod()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/test/ |
| D | ListenableFutureTest.kt | 35 val deferred = async { in <lambda>() constant
42 assertEquals(1, deferred.await()) in <lambda>()
48 val deferred = async { in <lambda>() constant
54 deferred.cancel(TestCancellationException()) in <lambda>()
55 deferred.await() // throws TCE in <lambda>()
143 val deferred = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
148 val future = deferred.asListenableFuture() in <lambda>()
156 val deferred = async { in <lambda>() constant
161 val future = deferred.asListenableFuture() in <lambda>()
168 val deferred = GlobalScope.async { in <lambda>() constant
[all …]
|
| /external/perfetto/ui/src/base/ |
| D | deferred_unittest.ts | 18 const deferred: Deferred<void> = defer<void>(); constant
20 deferred.then(() => i++);
23 deferred.resolve();
25 await deferred;
30 const deferred: Deferred<string> = defer<string>(); constant
31 deferred.resolve('foo');
32 return expect(deferred).resolves.toBe('foo');
36 const deferred: Deferred<string> = defer<string>(); constant
37 deferred.reject('foo');
38 return expect(deferred).rejects.toBe('foo');
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/test/ |
| D | PromiseTest.kt | 16 val deferred = promise.asDeferred() in <lambda>() constant
17 assertEquals("OK", deferred.await()) in <lambda>()
26 val deferred = promise.asDeferred() in <lambda>() constant
30 deferred.await() in <lambda>()
40 val deferred = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
44 val promise = deferred.asPromise() in <lambda>()
50 val deferred = async { in <lambda>() constant
54 val promise = deferred.asPromise() in <lambda>()
71 val deferred = async { "OK" } in <lambda>() constant
72 val promise = deferred.asPromise() in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ThreadLocalTest.kt | 27 val deferred = async(Dispatchers.Default + stringThreadLocal.asContextElement("value")) { in <lambda>() constant
40 deferred.await() in <lambda>()
49 val deferred = async(Dispatchers.Default + intThreadLocal.asContextElement(239)) { in <lambda>() constant
58 deferred.await() in <lambda>()
67 val deferred = async(Dispatchers.Default in <lambda>() constant
83 deferred.await() in <lambda>()
92 val deferred = GlobalScope.async(intThreadLocal.asContextElement(1)) { in <lambda>() constant
101 val deferred = async(intThreadLocal.asContextElement(53)) { in <lambda>() constant
105 deferred.await() in <lambda>()
116 deferred.await() in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/src/ |
| D | ListenableFuture.kt | 134 val deferred = CompletableDeferred<T>() in asDeferred() constant
139 deferred.complete(result as T) in asDeferred()
143 deferred.completeExceptionally(t) in asDeferred()
152 deferred.invokeOnCompletion { in asDeferred()
155 return deferred in asDeferred()
342 private class OuterFuture<T>(private val deferred: Deferred<T>): ListenableFuture<T> { constant in OuterFuture
343 val innerFuture = DeferredListenableFuture(deferred)
350 deferred.invokeOnCompletion { in afterInit()
374 || deferred.getCompletionExceptionOrNull() is kotlinx.coroutines.CancellationException) in isCancelled()
397 private fun getInternal(deferred: Deferred<T>): T { in getInternal()
[all …]
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/test/future/ |
| D | AsFutureTest.kt | 18 val deferred = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
23 val future = deferred.asCompletableFuture() in <lambda>()
38 val deferred = async { in <lambda>() constant
43 val future = deferred.asCompletableFuture() in <lambda>()
60 val deferred = GlobalScope.async<Unit> { throw OutOfMemoryError() } in testAsCompletableFutureThrowable() constant
61 val future = deferred.asCompletableFuture() in testAsCompletableFutureThrowable()
116 val deferred = CompletableDeferred<Int>() in testDeferredCancellation() constant
117 val future = deferred.asCompletableFuture() in testDeferredCancellation()
119 assertTrue(deferred.isCancelled) in testDeferredCancellation()
120 assertTrue(deferred.isCompleted) in testDeferredCancellation()
[all …]
|
| D | FutureTest.kt | 216 val deferred: Deferred<Int> = CompletableFuture.supplyAsync { in <lambda>() constant
220 assertFalse(deferred.isCompleted) in <lambda>()
223 assertEquals(42, deferred.await()) in <lambda>()
224 assertTrue(deferred.isCompleted) in <lambda>()
229 val deferred: Deferred<Int> = CompletableFuture.completedFuture(42).asDeferred() in <lambda>() constant
230 assertEquals(42, deferred.await()) in <lambda>()
238 val deferred = future.asDeferred() in <lambda>() constant
240 assertTrue(deferred.isCancelled) in <lambda>()
241 val completionException = deferred.getCompletionExceptionOrNull()!! in <lambda>()
246 deferred.await() in <lambda>()
[all …]
|
| /external/llvm-project/libcxx/test/std/thread/futures/futures.overview/ |
| D | launch.pass.cpp | 29 … (static_cast<int>(std::launch::async) | static_cast<int>(std::launch::deferred)), ""); in main()
31 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async | std::launch::deferred), ""); in main()
32 static_assert(std::launch(0) == (std::launch::async & std::launch::deferred), ""); in main()
33 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async ^ std::launch::deferred), ""); in main()
34 LIBCPP_STATIC_ASSERT(std::launch::deferred == ~std::launch::async, ""); in main()
36 x &= std::launch::deferred; in main()
39 x |= std::launch::deferred; in main()
41 x ^= std::launch::deferred; in main()
45 static_assert(static_cast<int>(std::launch::deferred) == 2, ""); in main()
|
| /external/libcxx/test/std/thread/futures/futures.overview/ |
| D | launch.pass.cpp | 30 … (static_cast<int>(std::launch::async) | static_cast<int>(std::launch::deferred)), ""); in main()
32 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async | std::launch::deferred), ""); in main()
33 static_assert(std::launch(0) == (std::launch::async & std::launch::deferred), ""); in main()
34 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async ^ std::launch::deferred), ""); in main()
35 LIBCPP_STATIC_ASSERT(std::launch::deferred == ~std::launch::async, ""); in main()
37 x &= std::launch::deferred; in main()
40 x |= std::launch::deferred; in main()
42 x ^= std::launch::deferred; in main()
46 static_assert(static_cast<int>(std::launch::deferred) == 2, ""); in main()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/test/ |
| D | TestBuildersTest.kt | 33 val deferred = scope.async { in scopeRunBlocking_advancesPreviousDelay() constant
40 assertEquals(3, deferred.await()) in scopeRunBlocking_advancesPreviousDelay()
49 val deferred = scope.async { in dispatcherRunBlocking_advancesPreviousDelay() constant
56 assertEquals(3, deferred.await()) in dispatcherRunBlocking_advancesPreviousDelay()
70 val deferred = scope.async { in scopeRunBlocking_disablesImmedateOnExit() constant
75 assertTrue(deferred.isActive) in scopeRunBlocking_disablesImmedateOnExit()
78 assertEquals(3, deferred.getCompleted()) in scopeRunBlocking_disablesImmedateOnExit()
87 val deferred = scope.async { in whenInAsync_runBlocking_nestsProperly() constant
100 assertEquals(3, deferred.getCompleted()) in whenInAsync_runBlocking_nestsProperly()
|
| D | TestRunBlockingTest.kt | 45 val deferred = async { in <lambda>() constant
51 assertEquals(3, deferred.await()) in <lambda>()
109 val deferred = async { in <lambda>() constant
113 assertEquals(3, deferred.await()) in <lambda>()
119 val deferred = async { in <lambda>() constant
126 deferred.await() in <lambda>()
133 val deferred = async { in <lambda>() constant
140 deferred.await() in <lambda>()
196 val deferred = async { in <lambda>() constant
202 deferred.await() in <lambda>()
|
| /external/llvm-project/flang/test/Semantics/ |
| D | resolve80.f90 | 17 procedure(subPublic), public, deferred, public :: publicBinding
19 procedure(subPrivate), private, deferred, private :: privateBinding
21 procedure(subDeferred), deferred, public, deferred :: deferredBinding
25 procedure(subNopass), nopass, deferred, nopass :: nopassBinding
27 procedure(subPass), pass, deferred, pass :: passBinding
29 procedure(subPassNopass), pass, deferred, nopass :: passNopassBinding ! C781
|
| /external/chromium-trace/catapult/third_party/polymer/components/promise-polyfill/ |
| D | Promise.js | 20 function handle(deferred) { argument
23 this._deferreds.push(deferred);
27 var cb = me._state ? deferred.onFulfilled : deferred.onRejected
29 (me._state ? deferred.resolve : deferred.reject)(me._value);
37 deferred.reject(e);
40 deferred.resolve(ret);
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/selects/ |
| D | SelectDeferredTest.kt | 141 val deferred = async { Wrapper("OK") } in <lambda>() constant
143 assertFalse(deferred.isCompleted) in <lambda>()
144 assertTrue(deferred.isActive) in <lambda>()
145 deferred.onAwait { in <lambda>()
155 val deferred = async(Dispatchers.Unconfined) { Wrapper("OK") } in <lambda>() constant
157 assertTrue(deferred.isCompleted) in <lambda>()
158 assertFalse(deferred.isActive) in <lambda>()
159 deferred.onAwait { in <lambda>()
|