| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ReusableCancellableContinuationTest.kt | 24 suspender: suspend ((CancellableContinuation<Unit>) -> Unit) -> Unit in testContinuationsCount()
26 val result = mutableSetOf<CancellableContinuation<*>>() in testContinuationsCount()
32 result.addAll(f.filterIsInstance<CancellableContinuation<*>>()) in testContinuationsCount()
150 FieldWalker.assertReachableCount(1, currentJob) { it is CancellableContinuation<*> } in <lambda>()
154 FieldWalker.assertReachableCount(0, currentJob) { it is CancellableContinuation<*> } in <lambda>()
163 FieldWalker.assertReachableCount(0, currentJob) { it is CancellableContinuation<*> } in <lambda>()
170 FieldWalker.assertReachableCount(0, currentJob) { it is CancellableContinuation<*> } in <lambda>()
194 FieldWalker.assertReachableCount(2, job) { it is CancellableContinuation<*> } in <lambda>()
199 FieldWalker.assertReachableCount(0, receiver) { it is CancellableContinuation<*> } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CancellableContinuation.kt | 114 public interface CancellableContinuation<in T> : Continuation<T> { in <lambda>() interface
313 internal fun <T> CancellableContinuation<T>.invokeOnCancellation(handler: CancelHandler) = when (th… in invokeOnCancellation()
424 crossinline block: (CancellableContinuation<T>) -> Unit in suspendCancellableCoroutine()
491 public fun CancellableContinuation<*>.disposeOnCancellation(handle: DisposableHandle): Unit = in disposeOnCancellation()
|
| D | Delay.kt | 45 … public fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit>) in <lambda>()
123 return suspendCancellableCoroutine sc@ { cont: CancellableContinuation<Unit> -> in delay()
|
| D | CompletionState.kt | 10 internal fun <T> Result<T>.toState(caller: CancellableContinuation<*>): Any? = in toState()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Window.kt | 33 private var current = ArrayDeque<CancellableContinuation<Double>>()
34 private var next = ArrayDeque<CancellableContinuation<Double>>()
37 fun enqueue(cont: CancellableContinuation<Double>) { in enqueue()
|
| D | Promise.kt | 63 …d fun <T> Promise<T>.await(): T = suspendCancellableCoroutine { cont: CancellableContinuation<T> -> in await()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | CancellableResumeOldTest.kt | 121 lateinit var cc: CancellableContinuation<String> in <lambda>()
140 lateinit var cc: CancellableContinuation<String> in <lambda>()
172 lateinit var cc: CancellableContinuation<String> in <lambda>()
203 lateinit var cc: CancellableContinuation<String> in <lambda>()
243 lateinit var cc: CancellableContinuation<String> in <lambda>()
|
| D | CancellableResumeTest.kt | 134 lateinit var cc: CancellableContinuation<String> in <lambda>()
153 lateinit var cc: CancellableContinuation<String> in <lambda>()
188 lateinit var cc: CancellableContinuation<String> in <lambda>()
222 lateinit var cc: CancellableContinuation<String> in <lambda>()
265 lateinit var cc: CancellableContinuation<String> in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/ |
| D | Semaphore.kt | 192 protected fun acquire(waiter: CancellableContinuation<Unit>) = acquire( in acquire()
297 is CancellableContinuation<*> -> { in addAcquireToQueue()
298 waiter as CancellableContinuation<Unit> in addAcquireToQueue()
340 is CancellableContinuation<*> -> { in tryResumeAcquire()
341 this as CancellableContinuation<Unit> in tryResumeAcquire()
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/src/ |
| D | JavaFxDispatcher.kt | 32 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in <lambda>()
96 private val next = CopyOnWriteArrayList<CancellableContinuation<Long>>()
105 fun onNext(cont: CancellableContinuation<Long>) { in onNext()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/common/src/ |
| D | TestDispatcher.kt | 28 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in scheduleResumeAfterDelay()
57 @JvmField val continuation: CancellableContinuation<Unit>, in timeoutMessage()
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-android/src/ |
| D | HandlerDispatcher.kt | 139 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in scheduleResumeAfterDelay()
202 private fun updateChoreographerAndPostFrameCallback(cont: CancellableContinuation<Long>) { in updateChoreographerAndPostFrameCallback()
207 private fun postFrameCallback(choreographer: Choreographer, cont: CancellableContinuation<Long>) { in postFrameCallback()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | MultithreadedDispatchers.kt | 27 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in scheduleResumeAfterDelay()
83 private val availableWorkers = Channel<CancellableContinuation<Runnable>>(Channel.UNLIMITED)
126 private fun obtainWorker(): CancellableContinuation<Runnable> = in obtainWorker()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/selects/ |
| D | SelectOld.kt | 126 private fun <T> CancellableContinuation<T>.resumeUndispatched(result: T) { in resumeUndispatched()
136 private fun CancellableContinuation<*>.resumeUndispatchedWithException(exception: Throwable) { in CancellableContinuation() method
|
| D | Select.kt | 638 is CancellableContinuation<*> -> { in trySelect()
643 val cont = curState as CancellableContinuation<Unit> in trySelect()
865 private fun CancellableContinuation<Unit>.tryResume( in tryResume() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jsAndWasmJsShared/src/internal/ |
| D | JSDispatcher.kt | 47 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in schedule()
58 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in dispatch()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Executors.kt | 138 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in scheduleResumeAfterDelay()
185 private val continuation: CancellableContinuation<Unit> in toString()
|
| D | Future.kt | 21 public fun CancellableContinuation<*>.cancelFutureOnCancellation(future: Future<*>): Unit = in cancelFutureOnCancellation()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/lincheck/ |
| D | ChannelsLincheckTest.kt | 178 private val senders = ArrayList<Pair<CancellableContinuation<Any>, Int>>()
179 private val receivers = ArrayList<CancellableContinuation<Any>>()
269 private fun <T> CancellableContinuation<T>.resume(res: T): Boolean { in resume()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxAwait.kt | 5 import kotlinx.coroutines.CancellableContinuation in <lambda>()
225 internal fun CancellableContinuation<*>.disposeOnCancellation(d: Disposable) = in awaitFirst()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | BufferedChannel.kt | 178 private fun onClosedSendOnNoWaiterSuspend(element: E, cont: CancellableContinuation<Unit>) { in <lambda>()
235 val cont: CancellableContinuation<Boolean> in <lambda>()
664 is CancellableContinuation<*> -> { // `receive()` in <lambda>()
665 this as CancellableContinuation<E> in <lambda>()
740 private fun onClosedReceiveOnNoWaiterSuspend(cont: CancellableContinuation<E>) { in <lambda>()
778 …private fun onClosedReceiveCatchingOnNoWaiterSuspend(cont: CancellableContinuation<ChannelResult<E… in <lambda>()
1168 is CancellableContinuation<*> -> { // suspended `send(e)` operation in <lambda>()
1170 this as CancellableContinuation<Unit> in <lambda>()
2204 …is CancellableContinuation<*> -> resumeWithException(if (receiver) receiveException else sendExcep… in <lambda>()
2620 is CancellableContinuation<*> -> { in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/src/ |
| D | ListenableFuture.kt | 239 return suspendCancellableCoroutine { cont: CancellableContinuation<T> -> in await()
258 val continuation: CancellableContinuation<T>
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxAwait.kt | 5 import kotlinx.coroutines.CancellableContinuation in <lambda>()
205 internal fun CancellableContinuation<*>.disposeOnCancellation(d: Disposable) = in disposeOnCancellation()
|
| /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 | 30 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in asCoroutineDispatcher()
|