| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | CompletableDeferredTest.kt | 14 val c = CompletableDeferred<String>() in testFresh()
20 val c = CompletableDeferred<String>() in testComplete()
31 val c = CompletableDeferred<DisposableHandle>() in testCompleteWithIncompleteResult()
39 private fun checkFresh(c: CompletableDeferred<*>) { in checkFresh()
48 private fun checkCompleteOk(c: CompletableDeferred<*>) { in checkCompleteOk()
56 private fun checkCancel(c: CompletableDeferred<String>) { in checkCancel()
66 val c = CompletableDeferred<String>() in testCancelWithException()
73 private fun checkCancelWithException(c: CompletableDeferred<String>) { in checkCancelWithException()
84 val c = CompletableDeferred<String>() in testCompleteWithResultOK()
95 val c = CompletableDeferred<String>() in testCompleteWithResultException()
[all …]
|
| D | AwaitTest.kt | 183 val d1 = CompletableDeferred(Unit) in <lambda>()
184 val d2 = CompletableDeferred(Unit) in <lambda>()
195 val d1 = CompletableDeferred(Unit) in <lambda>()
196 val d2 = CompletableDeferred(Unit) in <lambda>()
205 val d1 = CompletableDeferred<Unit>(parent = null) in <lambda>()
207 val d2 = CompletableDeferred<Unit>(parent = null) in <lambda>()
|
| D | ParentCancellationTest.kt | 36 val child = CompletableDeferred<Unit>(coroutineContext[Job]) in <lambda>()
132 val parent = CompletableDeferred<Unit>() // parent that handles exception (!) in <lambda>()
|
| D | CoroutineExceptionHandlerTest.kt | 37 val parent = CompletableDeferred<Unit>() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CompletableDeferred.kt | 25 public interface CompletableDeferred<T> : Deferred<T> { interface
60 public fun <T> CompletableDeferred<T>.completeWith(result: Result<T>): Boolean = in complete()
68 public fun <T> CompletableDeferred(parent: Job? = null): CompletableDeferred<T> = CompletableDeferr… in CompletableDeferred() method
74 public fun <T> CompletableDeferred(value: T): CompletableDeferred<T> = CompletableDeferredImpl<T>(n… in CompletableDeferred() method
82 ) : JobSupport(true), CompletableDeferred<T>, SelectClause1<T> {
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/src/ |
| D | Tasks.kt | 14 import kotlinx.coroutines.CompletableDeferred in <lambda>()
54 CompletableDeferred<T>().apply { if (isCanceled) cancel() else complete(result as T) } in asDeferred()
56 CompletableDeferred<T>().apply { completeExceptionally(e) } in asDeferred()
60 val result = CompletableDeferred<T>() in asDeferred()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/src/ |
| D | ListenableFuture.kt | 110 return CompletableDeferred<T>().also { in asDeferred()
122 CompletableDeferred(Uninterruptibles.getUninterruptibly(this)) in asDeferred()
124 CompletableDeferred<T>().also { it.cancel(e) } in asDeferred()
129 CompletableDeferred<T>().also { it.completeExceptionally(e.nonNullCause()) } in asDeferred()
134 val deferred = CompletableDeferred<T>() in asDeferred()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/test/ |
| D | TestRunBlockingTest.kt | 87 val uncompleted = CompletableDeferred<Unit>() in <lambda>()
97 val completed = CompletableDeferred<Unit>() in <lambda>()
255 val uncompleted = CompletableDeferred<Unit>() in <lambda>()
267 val uncompleted = CompletableDeferred<Unit>() in <lambda>()
278 val uncompleted = CompletableDeferred<Unit>() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | AwaitJvmTest.kt | 13 val d1 = CompletableDeferred<Int>() in <lambda>()
14 val d2 = CompletableDeferred<Int>() in <lambda>()
|
| D | JobChildStressTest.kt | 35 val parent = CompletableDeferred<Unit>() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoverySelectTest.kt | 27 val job = CompletableDeferred(Unit) in doSelect()
39 val deferred = CompletableDeferred<Unit>() in <lambda>()
|
| D | JobBasicCancellationTest.kt | 138 val child = CompletableDeferred<Unit>(coroutineContext[Job]) in <lambda>()
151 val deferred = CompletableDeferred<Int>() in testConsecutiveCancellation()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-sync-07.kt | 30 class GetCounter(val response: CompletableDeferred<Int>) : CounterMsg() // a request with reply
51 val response = CompletableDeferred<Int>() in <lambda>()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/src/future/ |
| D | Future.kt | 117 CompletableDeferred(get() as T) in asDeferred()
121 CompletableDeferred<T>().also { it.completeExceptionally(original) } in asDeferred()
124 val result = CompletableDeferred<T>() in asDeferred()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/test/future/ |
| D | AsFutureTest.kt | 76 CompletableDeferred<Unit>(parent = job).apply { completeExceptionally(OutOfMemoryError()) } in testJobAsCompletableFutureThrowable()
116 val deferred = CompletableDeferred<Int>() in testDeferredCancellation()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Share.kt | 319 val result = CompletableDeferred<StateFlow<T>>() in stateIn()
327 result: CompletableDeferred<StateFlow<T>> in launchSharingDeferred()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ProduceConsumeJvmTest.kt | 48 val received = CompletableDeferred<Int>() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | SanitizedProbesTest.kt | 107 val job = CompletableDeferred(Unit) in launchSelector()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/selects/ |
| D | SelectDeferredTest.kt | 125 val d = CompletableDeferred<String>() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/ |
| D | StateInTest.kt | 50 val sharingJob = CompletableDeferred<Unit>() in <lambda>()
|
| D | ShareInTest.kt | 91 val sharingJob = CompletableDeferred<Unit>() in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublishTest.kt | 137 val latch = CompletableDeferred<Unit>() in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublishTest.kt | 137 val latch = CompletableDeferred<Unit>() in <lambda>()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/test/ |
| D | ListenableFutureTest.kt | 328 val deferred = CompletableDeferred<Int>() in <lambda>()
363 val deferred = CompletableDeferred<Int>() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 107 public abstract interface class kotlinx/coroutines/CompletableDeferred : kotlinx/coroutines/Deferre…
112 public final class kotlinx/coroutines/CompletableDeferred$DefaultImpls {
113 public static synthetic fun cancel (Lkotlinx/coroutines/CompletableDeferred;)V
114 …public static fun fold (Lkotlinx/coroutines/CompletableDeferred;Ljava/lang/Object;Lkotlin/jvm/func…
115 …public static fun get (Lkotlinx/coroutines/CompletableDeferred;Lkotlin/coroutines/CoroutineContext…
116 …public static fun minusKey (Lkotlinx/coroutines/CompletableDeferred;Lkotlin/coroutines/CoroutineCo…
117 …public static fun plus (Lkotlinx/coroutines/CompletableDeferred;Lkotlin/coroutines/CoroutineContex…
118 …public static fun plus (Lkotlinx/coroutines/CompletableDeferred;Lkotlinx/coroutines/Job;)Lkotlinx/…
122 …public static final fun CompletableDeferred (Ljava/lang/Object;)Lkotlinx/coroutines/CompletableDef…
123 …public static final fun CompletableDeferred (Lkotlinx/coroutines/Job;)Lkotlinx/coroutines/Completa…
[all …]
|