| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | CancellableContinuationHandlersTest.kt | 16 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
24 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
36 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
49 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
65 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
88 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
118 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
134 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
153 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
|
| D | CancellableResumeTest.kt | 18 val ok = suspendCancellableCoroutine<String> { cont -> in <lambda>()
33 suspendCancellableCoroutine<String> { cont -> in <lambda>()
56 suspendCancellableCoroutine<String> { cont -> in <lambda>()
80 suspendCancellableCoroutine<String> { cont -> in <lambda>()
103 suspendCancellableCoroutine<String> { cont -> in <lambda>()
126 val ok = suspendCancellableCoroutine<String> { cont -> in <lambda>()
146 suspendCancellableCoroutine<String> { cont -> in <lambda>()
178 suspendCancellableCoroutine<String> { cont -> in <lambda>()
209 suspendCancellableCoroutine<String> { cont -> in <lambda>()
249 suspendCancellableCoroutine<String> { cont -> in <lambda>()
[all …]
|
| D | CancellableContinuationTest.kt | 18 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
39 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
57 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
80 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
105 suspendCancellableCoroutine<Unit> { c -> in <lambda>()
126 suspendCancellableCoroutine<Unit> { cont -> in <lambda>()
|
| D | TestBase.common.kt | 33 suspendCancellableCoroutine<Unit> { } in hang()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxAwait.kt | 12 import kotlinx.coroutines.suspendCancellableCoroutine in <lambda>()
24 public suspend fun CompletableSource.await(): Unit = suspendCancellableCoroutine { cont -> in <lambda>()
55 public suspend fun <T> MaybeSource<T>.awaitOrDefault(default: T): T = suspendCancellableCoroutine {… in await()
74 public suspend fun <T> SingleSource<T>.await(): T = suspendCancellableCoroutine { cont -> in await()
167 ): T = suspendCancellableCoroutine { cont -> in toString()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxAwait.kt | 12 import kotlinx.coroutines.suspendCancellableCoroutine in <lambda>()
24 public suspend fun CompletableSource.await(): Unit = suspendCancellableCoroutine { cont -> in <lambda>()
55 public suspend fun <T> MaybeSource<T>.awaitOrDefault(default: T): T = suspendCancellableCoroutine {… in await()
74 public suspend fun <T> SingleSource<T>.await(): T = suspendCancellableCoroutine { cont -> in await()
167 ): T = suspendCancellableCoroutine { cont -> in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Delay.kt | 33 return suspendCancellableCoroutine { scheduleResumeAfterDelay(time, it) } in <lambda>()
98 public suspend fun awaitCancellation(): Nothing = suspendCancellableCoroutine {} in <lambda>()
118 return suspendCancellableCoroutine sc@ { cont: CancellableContinuation<Unit> -> in delay()
|
| D | Await.kt | 72 suspend fun await(): List<T> = suspendCancellableCoroutine { cont -> in await()
|
| D | CancellableContinuation.kt | 305 public suspend inline fun <T> suspendCancellableCoroutine( in suspendCancellableCoroutine() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | CancellableContinuationJvmTest.kt | 17 suspendCancellableCoroutine<Unit> { in checkToString()
27 suspendCancellableCoroutine<Unit> { in <lambda>()
59 private suspend fun BlockingSource.await() = suspendCancellableCoroutine<Unit> { in <lambda>()
|
| D | ReusableCancellableContinuationTest.kt | 21 testContinuationsCount(10, 10, ::suspendCancellableCoroutine) in <lambda>()
113 suspendCancellableCoroutine<Unit> { in <lambda>()
|
| D | JobStructuredJoinStressTest.kt | 26 suspendCancellableCoroutine { cont -> in <lambda>()
|
| D | CancellableContinuationResumeCloseStressTest.kt | 50 private suspend fun resumeClose() = suspendCancellableCoroutine<String> { cont -> in <lambda>()
|
| D | ContinuationSerializationTest.kt | 59 private suspend fun serializeCancellable() = suspendCancellableCoroutine<Unit> { cont -> in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/tailcall/ |
| D | SimpleChannel.kt | 73 override suspend fun suspendReceive(): Int = suspendCancellableCoroutine { in <lambda>()
78 override suspend fun suspendSend(element: Int) = suspendCancellableCoroutine<Unit> { in <lambda>()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/src/ |
| D | Tasks.kt | 17 import kotlinx.coroutines.suspendCancellableCoroutine in <lambda>()
96 return suspendCancellableCoroutine { cont -> in await()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Await.kt | 9 import kotlinx.coroutines.suspendCancellableCoroutine in <lambda>()
136 ): T = suspendCancellableCoroutine { cont -> in awaitOne()
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-android/src/ |
| D | HandlerDispatcher.kt | 171 return suspendCancellableCoroutine { cont -> in equals()
176 return suspendCancellableCoroutine { cont -> in equals()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/junit4/ |
| D | CoroutinesTimeoutEagerTest.kt | 31 suspendCancellableCoroutine<Unit> { } in hangForever()
|
| D | CoroutinesTimeoutDisabledTracesTest.kt | 33 suspendCancellableCoroutine<Unit> { } in hangForever()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | DebugLeaksTest.kt | 52 private suspend fun suspendForever() = suspendCancellableCoroutine<Unit> { } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Window.kt | 25 public suspend fun Window.awaitAnimationFrame(): Double = suspendCancellableCoroutine { cont -> in cont()
|
| D | Promise.kt | 68 public suspend fun <T> Promise<T>.await(): T = suspendCancellableCoroutine { cont: CancellableConti… in await()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/linearizability/ |
| D | ChannelsLCStressTest.kt | 136 false -> suspendCancellableCoroutine { cont -> in offerRes()
166 suspend fun receive(): Any = poll() ?: suspendCancellableCoroutine { cont -> in receive()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Produce.kt | 52 suspendCancellableCoroutine<Unit> { cont -> in cont()
|