| /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 { 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 | 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>()
|
| /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 nestedMethod()
74 oneMoreNestedMethod(deferred, *traces) in nestedMethod()
78 private suspend fun oneMoreNestedMethod(deferred: Deferred<*>, vararg traces: String) { in oneMoreNestedMethod()
80 deferred.await() in oneMoreNestedMethod()
[all …]
|
| D | JobBasicCancellationTest.kt | 100 val deferred = async(NonCancellable) { in <lambda>() constant
114 deferred.await() in <lambda>()
151 val deferred = CompletableDeferred<Int>() in testConsecutiveCancellation() constant
152 assertTrue(deferred.completeExceptionally(IndexOutOfBoundsException())) in testConsecutiveCancellation()
153 assertFalse(deferred.completeExceptionally(AssertionError())) // second is too late in testConsecutiveCancellation()
154 val cause = deferred.getCancellationException().cause!! in testConsecutiveCancellation()
|
| D | StackTraceRecoveryNestedScopesTest.kt | 69 val deferred = async(NonCancellable) { in <lambda>() constant
73 verifyAwait(deferred) in <lambda>()
76 private suspend fun verifyAwait(deferred: Deferred<Unit>) { in verifyAwait()
78 deferred.await() in verifyAwait()
|
| /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
61 nestedMethod(deferred, traces) in <lambda>()
62 deferred.join() in <lambda>()
70 val deferred = createDeferred() in <lambda>() constant
85 nestedMethod(deferred, traces) in <lambda>()
86 deferred.join() in <lambda>()
90 private suspend fun nestedMethod(deferred: Deferred<*>, traces: List<String>) { in nestedMethod()
[all …]
|
| D | CoroutinesDumpTest.kt | 17 val deferred = GlobalScope.async { in <lambda>() constant
32 val found = DebugProbes.dumpCoroutinesInfo().single { it.job === deferred } in <lambda>()
33 assertSame(deferred, found.job) in <lambda>()
34 runBlocking { deferred.cancelAndJoin() } in <lambda>()
39 val deferred = GlobalScope.async { in <lambda>() constant
57 runBlocking { deferred.cancelAndJoin() } in <lambda>()
62 val deferred = GlobalScope.async { in <lambda>() constant
85 runBlocking { deferred.cancelAndJoin() } in <lambda>()
90 val deferred = GlobalScope.async { in <lambda>() constant
101 runBlocking { deferred.cancelAndJoin() } in <lambda>()
[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 | 36 val deferred = async { in <lambda>() constant
43 assertEquals(1, deferred.await()) in <lambda>()
49 val deferred = async { in <lambda>() constant
55 deferred.cancel(TestCancellationException()) in <lambda>()
56 deferred.await() // throws TCE in <lambda>()
144 val deferred = async(start = CoroutineStart.UNDISPATCHED) { in <lambda>() constant
149 val future = deferred.asListenableFuture() in <lambda>()
157 val deferred = async { in <lambda>() constant
162 val future = deferred.asListenableFuture() in <lambda>()
169 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/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/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/integration/kotlinx-coroutines-guava/src/ |
| D | ListenableFuture.kt | 142 val deferred = CompletableDeferred<T>() in asDeferred() constant
145 deferred.complete(result!!) in asDeferred()
149 deferred.completeExceptionally(t) in asDeferred()
158 deferred.invokeOnCompletion { in asDeferred()
161 return deferred in asDeferred()
348 private class OuterFuture<T>(private val deferred: Deferred<T>): ListenableFuture<T> { constant in OuterFuture
349 val innerFuture = DeferredListenableFuture(deferred)
356 deferred.invokeOnCompletion { in afterInit()
380 || deferred.getCompletionExceptionOrNull() is kotlinx.coroutines.CancellationException) in isCancelled()
403 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/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/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>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | CancellableContinuationBenchmark.kt | 23 val deferred = CompletableDeferred<Int>() in awaitWithSuspension() constant
24 return run(allowSuspend = true) { deferred.await() } in awaitWithSuspension()
29 val deferred = CompletableDeferred(1) in awaitNoSuspension() constant
30 return run { deferred.await() } in awaitNoSuspension()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Promise.kt | 46 promise.asDynamic().deferred = this in <lambda>()
54 val deferred = asDynamic().deferred in asDeferred() constant
56 return deferred ?: GlobalScope.async(start = CoroutineStart.UNDISPATCHED) { await() } in asDeferred()
|
| /external/tcpdump/tests/ |
| D | sflow_multiple_counter_30_pdus.out | 13 deferred 0, late collision 0, excessive collision 0, mac trans error 0
25 deferred 0, late collision 0, excessive collision 0, mac trans error 0
37 deferred 0, late collision 0, excessive collision 0, mac trans error 0
49 deferred 0, late collision 0, excessive collision 0, mac trans error 0
61 deferred 0, late collision 0, excessive collision 0, mac trans error 0
73 deferred 0, late collision 0, excessive collision 0, mac trans error 0
85 deferred 0, late collision 0, excessive collision 0, mac trans error 0
99 deferred 0, late collision 0, excessive collision 0, mac trans error 0
111 deferred 0, late collision 0, excessive collision 0, mac trans error 0
123 deferred 0, late collision 0, excessive collision 0, mac trans error 0
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/test/ |
| D | TestCoroutineContextTest.kt | 114 val deferred = async { in <lambda>() constant
122 deferred.getCompleted() in <lambda>()
129 assertEquals(expectedValue, deferred.getCompleted()) in <lambda>()
158 val deferred = async { in <lambda>() constant
167 deferred.getCompleted() in <lambda>()
175 assertEquals(expectedValue, deferred.getCompleted()) in <lambda>()
349 val deferred = async { in suspendedAsyncWithExceptionAfterDelay() constant
355 deferred.await() in suspendedAsyncWithExceptionAfterDelay()
|