Home
last modified time | relevance | path

Searched refs:resumeWith (Results 1 – 25 of 45) sorted by relevance

12

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/
DDispatchedContinuation.kt178 override fun resumeWith(result: Result<T>) { in <lambda>() method
188 continuation.resumeWith(result) in <lambda>()
239 continuation.resumeWith(result) in <lambda>()
266 else -> resumeWith(result) in resumeCancellableWith()
DDispatchedTask.kt178 else -> delegate.resumeWith(result) in resume()
219 resumeWith(Result.failure(recoverStackTrace(exception, this))) in resumeWithStackTrace()
DScopes.kt32 uCont.resumeWith(recoverResult(state, uCont)) in afterResume()
/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/
DTakeBenchmark.kt121 override fun resumeWith(result: Result<Unit>) { in <lambda>() method in benchmarks.flow.TakeBenchmark
123 … if (++consumed == count) completion.resumeWith(Result.failure(StacklessCancellationException())) in <lambda>()
124 else completion.resumeWith(Result.success(Unit)) in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DDelayJvmTest.kt67 override fun resumeWith(result: Result<T>) { in <lambda>() method in kotlinx.coroutines.DelayJvmTest.Wrapper
68 pool.execute { cont.resumeWith(result) } in <lambda>()
DReusableCancellableContinuationTest.kt36 it.resumeWith(Result.success(Unit)) in testContinuationsCount()
96 cont!!.resumeWith(Result.success(Unit)) in <lambda>()
111 cont!!.resumeWith(Result.success(Unit)) in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/flow/internal/
DSafeCollector.kt41 completion?.resumeWith(result as Result<Unit>) in <lambda>()
137 override fun resumeWith(result: Result<Any?>) { in resumeWith() method
/external/kotlinx.atomicfu/atomicfu/src/jvmMain/kotlin/kotlinx/atomicfu/
DLockFreedomTestEnvironment.kt333 continuation.resumeWith(result) in <lambda>()
357 private fun resumeWith(result: Result<Any?>, continuation: Continuation<Any?>?) { in <lambda>() method in kotlinx.atomicfu.LockFreedomTestEnvironment
400 resumeWith(it, continuation as Continuation<Any?>) in <lambda>()
405 resumeWith(it, null) in <lambda>()
/external/kotlinx.coroutines/stdlib-stubs/src/
DContinuation.kt9 public fun resumeWith(result: Result<T>) method
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test-resources/stacktraces/select/
DtestSelectCompletedAwait.txt7 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestSelectJoin.txt7 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test-resources/stacktraces/channels/
DtestSendToClosedChannel.txt8 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestReceiveFromClosedChannel.txt8 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestReceiveOrNullFromClosedChannel.txt8 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestReceiveFromChannel.txt8 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestOfferWithContextWrapped.txt9 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestOfferWithCurrentContext.txt9 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestOfferFromScope.txt10 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestSendFromScope.txt10 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestCancelledOffer.txt10 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test-resources/stacktraces/resume-mode/
DtestUnconfinedSuspending.txt9 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestEventLoopDispatcherSuspending.txt10 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
DtestNestedEventLoopChangedContextSuspending.txt11 at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/selects/
DSelect.kt295 override fun resumeWith(result: Result<R>) { in next() method in kotlinx.coroutines.selects.SelectBuilderImpl
300 uCont.resumeWith(result) in next()
308 uCont.intercepted().resumeWith(Result.failure(exception)) in next()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/
DOnCompletionInterceptedReleaseTest.kt38 return Continuation(continuation.context) { continuation.resumeWith(it) } in <lambda>()

12