Searched refs:tryResume (Results 1 – 8 of 8) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CancellableContinuation.kt | 78 public fun tryResume(value: T, idempotent: Any? = null): Any? in <lambda>() method
86 …public fun tryResume(value: T, idempotent: Any?, onCancellation: ((cause: Throwable) -> Unit)?): A… in <lambda>() method
|
| D | CancellableContinuationImpl.kt | 260 private fun tryResume(): Boolean { in <lambda>() method
360 if (tryResume()) return // completed before getResult invocation -- bail out in <lambda>()
467 override fun tryResume(value: T, idempotent: Any?): Any? = in <lambda>() method
470 …override fun tryResume(value: T, idempotent: Any?, onCancellation: ((cause: Throwable) -> Unit)?):… in <lambda>() method
|
| D | Builders.common.kt | 242 private fun tryResume(): Boolean { in tryResume() method
259 if (tryResume()) return // completed before getResult invocation -- bail out in afterResume()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | AbstractChannel.kt | 892 …val token = cont.tryResume(resumeValue(value), otherOp?.desc, resumeOnCancellationFun(value)) ?: r… in tryResumeReceive()
925 val token = cont.tryResume(true, otherOp?.desc, resumeOnCancellationFun(value)) in tryResumeReceive()
944 cont.tryResume(false) in resumeReceiveClosed()
1070 val token = cont.tryResume(Unit, otherOp?.desc) ?: return null in tryResumeReceive()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/ |
| D | Semaphore.kt | 245 val token = tryResume(Unit, null, onCancellationRelease) ?: return false in tryResumeAcquire()
|
| D | Mutex.kt | 363 override fun tryResumeLockWaiter() = cont.tryResume(Unit, idempotent = null) { in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/linearizability/ |
| D | ChannelsLCStressTest.kt | 221 val token = tryResume(res) ?: return false in extractState()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 48 public abstract fun tryResume (Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
49 …public abstract fun tryResume (Ljava/lang/Object;Ljava/lang/Object;Lkotlin/jvm/functions/Function1…
55 …public static synthetic fun tryResume$default (Lkotlinx/coroutines/CancellableContinuation;Ljava/l…
80 public fun tryResume (Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
81 …public fun tryResume (Ljava/lang/Object;Ljava/lang/Object;Lkotlin/jvm/functions/Function1;)Ljava/l…
|