| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ReusableCancellableContinuationTest.kt | 27 suspender: suspend ((CancellableContinuation<Unit>) -> Unit) -> Unit in testContinuationsCount()
29 val result = mutableSetOf<CancellableContinuation<*>>() in testContinuationsCount()
35 result.addAll(f.filterIsInstance<CancellableContinuation<*>>()) in testContinuationsCount()
153 FieldWalker.assertReachableCount(1, currentJob) { it is CancellableContinuation<*> } in <lambda>()
157 FieldWalker.assertReachableCount(0, currentJob) { it is CancellableContinuation<*> } in <lambda>()
166 FieldWalker.assertReachableCount(0, currentJob) { it is CancellableContinuation<*> } in <lambda>()
173 FieldWalker.assertReachableCount(0, currentJob) { it is CancellableContinuation<*> } in <lambda>()
197 FieldWalker.assertReachableCount(2, job) { it is CancellableContinuation<*> } in <lambda>()
202 FieldWalker.assertReachableCount(0, receiver) { it is CancellableContinuation<*> } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CancellableContinuation.kt | 48 public interface CancellableContinuation<in T> : Continuation<T> { in <lambda>() interface
306 crossinline block: (CancellableContinuation<T>) -> Unit in suspendCancellableCoroutine()
325 crossinline block: (CancellableContinuation<T>) -> Unit in suspendCancellableCoroutineReusable()
359 internal fun CancellableContinuation<*>.removeOnCancellation(node: LockFreeLinkedListNode) = in removeOnCancellation()
373 public fun CancellableContinuation<*>.disposeOnCancellation(handle: DisposableHandle): Unit = in removeOnCancellation()
|
| D | Delay.kt | 51 … public fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit>) in <lambda>()
118 return suspendCancellableCoroutine sc@ { cont: CancellableContinuation<Unit> -> in delay()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Window.kt | 38 private var current = ArrayQueue<CancellableContinuation<Double>>()
39 private var next = ArrayQueue<CancellableContinuation<Double>>()
42 fun enqueue(cont: CancellableContinuation<Double>) { in enqueue()
|
| D | JSDispatcher.kt | 43 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in <lambda>()
80 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in toString()
|
| D | Promise.kt | 68 …d fun <T> Promise<T>.await(): T = suspendCancellableCoroutine { cont: CancellableContinuation<T> -> in await()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | CancellableResumeTest.kt | 123 lateinit var cc: CancellableContinuation<String> in <lambda>()
142 lateinit var cc: CancellableContinuation<String> in <lambda>()
174 lateinit var cc: CancellableContinuation<String> in <lambda>()
205 lateinit var cc: CancellableContinuation<String> in <lambda>()
245 lateinit var cc: CancellableContinuation<String> in <lambda>()
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/src/ |
| D | JavaFxDispatcher.kt | 37 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in <lambda>()
105 val next = CopyOnWriteArrayList<CancellableContinuation<Long>>()
114 fun onNext(cont: CancellableContinuation<Long>) { in onNext()
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-android/src/ |
| D | HandlerDispatcher.kt | 135 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in scheduleResumeAfterDelay()
183 private fun updateChoreographerAndPostFrameCallback(cont: CancellableContinuation<Long>) { in updateChoreographerAndPostFrameCallback()
189 private fun postFrameCallback(choreographer: Choreographer, cont: CancellableContinuation<Long>) { in postFrameCallback()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/src/ |
| D | TestCoroutineDispatcher.kt | 63 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in <lambda>()
191 @JvmField val continuation: CancellableContinuation<T>,
192 private val block: CancellableContinuation<T>.() -> Unit
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/ |
| D | Semaphore.kt | 195 private fun addAcquireToQueue(cont: CancellableContinuation<Unit>): Boolean { in addAcquireToQueue()
240 else -> return (cellState as CancellableContinuation<Unit>).tryResumeAcquire() in tryResumeNextFromQueue()
244 private fun CancellableContinuation<Unit>.tryResumeAcquire(): Boolean { in tryResumeAcquire() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/linearizability/ |
| D | ChannelsLCStressTest.kt | 129 private val senders = ArrayList<Pair<CancellableContinuation<Any>, Int>>()
130 private val receivers = ArrayList<CancellableContinuation<Any>>()
220 private fun <T> CancellableContinuation<T>.resume(res: T): Boolean { in extractState()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Executors.kt | 107 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in scheduleResumeAfterDelay()
158 private val continuation: CancellableContinuation<Unit> in toString()
|
| D | Future.kt | 32 public fun CancellableContinuation<*>.cancelFutureOnCancellation(future: Future<*>): Unit = in cancelFutureOnCompletion()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | AbstractChannel.kt | 572 ReceiveElement(cont as CancellableContinuation<Any?>, receiveMode) else in receiveSuspend()
573 …ReceiveElementWithUndeliveredHandler(cont as CancellableContinuation<Any?>, receiveMode, onUndeliv… in receiveSuspend()
812 private fun removeReceiveOnCancel(cont: CancellableContinuation<*>, receive: Receive<*>) = in removeReceiveOnCancel()
883 @JvmField val cont: CancellableContinuation<Any?>,
912 cont: CancellableContinuation<Any?>, in toString()
922 @JvmField val cont: CancellableContinuation<Boolean>
1067 @JvmField val cont: CancellableContinuation<Unit> in tryResumeReceive()
1084 cont: CancellableContinuation<Unit>,
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxAwait.kt | 9 import kotlinx.coroutines.CancellableContinuation in <lambda>()
153 internal fun CancellableContinuation<*>.disposeOnCancellation(d: Disposable) = in awaitFirst()
|
| D | RxScheduler.kt | 33 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in asCoroutineDispatcher()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxAwait.kt | 9 import kotlinx.coroutines.CancellableContinuation in <lambda>()
153 internal fun CancellableContinuation<*>.disposeOnCancellation(d: Disposable) = in awaitFirst()
|
| D | RxScheduler.kt | 33 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in asCoroutineDispatcher()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/src/ |
| D | ListenableFuture.kt | 232 return suspendCancellableCoroutine { cont: CancellableContinuation<T> -> in await()
251 val continuation: CancellableContinuation<T>
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-swing/api/ |
| D | kotlinx-coroutines-swing.api | 5 public fun scheduleResumeAfterDelay (JLkotlinx/coroutines/CancellableContinuation;)V
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | Scheduler.kt | 34 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in asCoroutineDispatcher()
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/api/ |
| D | kotlinx-coroutines-javafx.api | 9 public fun scheduleResumeAfterDelay (JLkotlinx/coroutines/CancellableContinuation;)V
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | CoroutineContext.kt | 17 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in takeEventLoop()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/src/internal/ |
| D | MainTestDispatcher.kt | 41 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in isDispatchNeeded()
|