Home
last modified time | relevance | path

Searched refs:Continuation (Results 1 – 25 of 118) sorted by relevance

12345

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/
DOnCompletionInterceptedReleaseTest.kt16 var cont: Continuation<Unit>? = null in <lambda>()
36 override fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T> { in <lambda>()
38 return Continuation(continuation.context) { continuation.resumeWith(it) } in <lambda>()
41 override fun releaseInterceptedContinuation(continuation: Continuation<*>) { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/intrinsics/
DCancellable.kt17 public fun <T> (suspend () -> T).startCoroutineCancellable(completion: Continuation<T>): Unit = run… in <lambda>()
26 receiver: R, completion: Continuation<T>, in startCoroutineCancellable()
37 internal fun Continuation<Unit>.startCoroutineCancellable(fatalCompletion: Continuation<*>) = in startCoroutineCancellable()
48 private inline fun runSafely(completion: Continuation<*>, block: () -> Unit) { in runSafely()
DUndispatched.kt17 internal fun <T> (suspend () -> T).startCoroutineUnintercepted(completion: Continuation<T>) { in <lambda>()
28 …n <R, T> (suspend (R) -> T).startCoroutineUnintercepted(receiver: R, completion: Continuation<T>) { in startCoroutineUnintercepted()
39 internal fun <T> (suspend () -> T).startCoroutineUndispatched(completion: Continuation<T>) { in startCoroutineUndispatched()
52 …un <R, T> (suspend (R) -> T).startCoroutineUndispatched(receiver: R, completion: Continuation<T>) { in startCoroutineUndispatched()
65 private inline fun <T> startDirect(completion: Continuation<T>, block: (Continuation<T>) -> Any?) { in startDirect()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/
DCancellableContinuationTest.kt14 var continuation: Continuation<Unit>? = null in <lambda>()
36 var continuation: Continuation<Unit>? = null in <lambda>()
54 var continuation: Continuation<Unit>? = null in <lambda>()
76 var continuation: Continuation<Unit>? = null in <lambda>()
101 var continuation: Continuation<Unit>? = null in <lambda>()
135 coroutineBlock.startCoroutine(Continuation(completableJob) { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-debug/src/internal/
DNoOpProbes.kt15 internal fun probeCoroutineResumedNoOp(frame: Continuation<*>) = Unit
17 internal fun probeCoroutineSuspendedNoOp(frame: Continuation<*>) = Unit
19 …eCoroutineCreatedNoOp(completion: kotlin.coroutines.Continuation<T>): kotlin.coroutines.Continuati…
/external/kotlinx.coroutines/integration-testing/src/debugAgentTest/kotlin/
DDebugProbes.kt10 internal fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T> = DebugProbesI…
12 internal fun probeCoroutineResumed(frame: Continuation<*>) = DebugProbesImpl.probeCoroutineResumed(…
14 internal fun probeCoroutineSuspended(frame: Continuation<*>) = DebugProbesImpl.probeCoroutineSuspen…
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/api/
Dkotlinx-coroutines-jdk9.api2 …n awaitFirst (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
3 …a/util/concurrent/Flow$Publisher;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
4 …ent/Flow$Publisher;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
5 …tFirstOrNull (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
6 …un awaitLast (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
7 … awaitSingle (Ljava/util/concurrent/Flow$Publisher;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
20 …ent/Flow$Publisher;Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
/external/kotlinx.coroutines/stdlib-stubs/src/
DContinuationInterceptor.kt9 public fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T> in interceptContinuation()
10 public fun releaseInterceptedContinuation(continuation: Continuation<*>): Continuation<*> { in interceptContinuation()
/external/kotlinx.coroutines/kotlinx-coroutines-core/api/
Dkotlinx-coroutines-core.api1 …/AbstractCoroutine : kotlinx/coroutines/JobSupport, kotlin/coroutines/Continuation, kotlinx/corout…
20 …public static final fun awaitAll (Ljava/util/Collection;Lkotlin/coroutines/Continuation;)Ljava/lan…
21 …public static final fun awaitAll ([Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/Continuation;)L…
22 …public static final fun joinAll (Ljava/util/Collection;Lkotlin/coroutines/Continuation;)Ljava/lang…
23 …public static final fun joinAll ([Lkotlinx/coroutines/Job;Lkotlin/coroutines/Continuation;)Ljava/l…
29 …oroutineDispatcher;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
34 …s/CoroutineContext;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
37 …tract interface class kotlinx/coroutines/CancellableContinuation : kotlin/coroutines/Continuation {
59 public fun <init> (Lkotlin/coroutines/Continuation;I)V
87 …cellableCoroutine (Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
[all …]
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/
Dkotlinx-coroutines-reactive.api2 …public static final fun awaitFirst (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuation…
3 … (Lorg/reactivestreams/Publisher;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
4 …estreams/Publisher;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
5 …n awaitFirstOrNull (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
6 …public static final fun awaitLast (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuation;…
7 …al fun awaitSingle (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
8 … (Lorg/reactivestreams/Publisher;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
9 …estreams/Publisher;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
10 … awaitSingleOrNull (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
14 …estreams/Publisher;Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
[all …]
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/api/
Dkotlinx-coroutines-rx3.api2 …wait (Lio/reactivex/rxjava3/core/CompletableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
3 … fun await (Lio/reactivex/rxjava3/core/MaybeSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
4 …fun await (Lio/reactivex/rxjava3/core/SingleSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
5 …First (Lio/reactivex/rxjava3/core/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
6 …ex/rxjava3/core/ObservableSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
7 …e/ObservableSource;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
8 …rNull (Lio/reactivex/rxjava3/core/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
9 …tLast (Lio/reactivex/rxjava3/core/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
10 …activex/rxjava3/core/MaybeSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
11 …ingle (Lio/reactivex/rxjava3/core/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/debug/internal/
DDebugProbesImpl.kt342 internal fun probeCoroutineResumed(frame: Continuation<*>) = updateState(frame, RUNNING) in <lambda>()
344 internal fun probeCoroutineSuspended(frame: Continuation<*>) = updateState(frame, SUSPENDED) in <lambda>()
346 private fun updateState(frame: Continuation<*>, state: String) { in <lambda>()
375 info.updateState(state, frame as Continuation<*>) in <lambda>()
386 …private fun updateState(owner: CoroutineOwner<*>, frame: Continuation<*>, state: String) = corouti… in <lambda>()
391 … private fun Continuation<*>.owner(): CoroutineOwner<*>? = (this as? CoroutineStackFrame)?.owner() in <lambda>() method
397 internal fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T> { in <lambda>()
424 …private fun <T> createOwner(completion: Continuation<T>, frame: StackTraceFrame?): Continuation<T>… in <lambda>()
449 @JvmField val delegate: Continuation<T>, in <lambda>()
452 ) : Continuation<T> by delegate, CoroutineStackFrame { in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/api/
Dkotlinx-coroutines-rx2.api2 …public static final fun await (Lio/reactivex/CompletableSource;Lkotlin/coroutines/Continuation;)Lj…
3 …public static final fun await (Lio/reactivex/MaybeSource;Lkotlin/coroutines/Continuation;)Ljava/la…
4 …public static final fun await (Lio/reactivex/SingleSource;Lkotlin/coroutines/Continuation;)Ljava/l…
5 …public static final fun awaitFirst (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation…
6 … (Lio/reactivex/ObservableSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
7 …x/ObservableSource;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
8 …n awaitFirstOrNull (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
9 …public static final fun awaitLast (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation;…
10 …fault (Lio/reactivex/MaybeSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
11 …al fun awaitSingle (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/flow/internal/
DSafeCollector.kt15 FlowCollector<Any?>::emit as Function3<FlowCollector<Any?>, Any?, Continuation<Unit>, Any?> in <lambda>()
33 private var completion: Continuation<Unit>? = null in <lambda>()
68 private fun emit(uCont: Continuation<Unit>, value: T): Any? { in <lambda>()
77 return emitFun(collector as FlowCollector<Any?>, value, this as Continuation<Unit>) in <lambda>()
134 private object NoOpContinuation : Continuation<Any?> {
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DDelayJvmTest.kt59 override fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T> = in <lambda>()
63 class Wrapper<T>(val pool: Executor, private val cont: Continuation<T>) : Continuation<T> { in <lambda>()
DReusableCancellableContinuationTest.kt31 val channel = Channel<Continuation<Unit>>(1) in testContinuationsCount()
66 var continuation: Continuation<*>? = null
94 var cont: Continuation<Unit>? = null in <lambda>()
109 var cont: Continuation<Unit>? = null in <lambda>()
124 var cont: Continuation<*>? = null in testDetachedOnCancel()
DContinuationSerializationTest.kt71 …private fun testSerization(serialize: KSuspendFunction0<Unit>, patcher: (Continuation<Unit>) -> Un… in <lambda>()
88 private fun deserialise(): Continuation<Unit> { in <lambda>()
91 return kryo.readClassAndObject(it) as Continuation<Unit> in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-debug/src/
DDebugProbes.kt148 internal fun probeCoroutineResumed(frame: Continuation<*>) = DebugProbesImpl.probeCoroutineResumed(…
150 internal fun probeCoroutineSuspended(frame: Continuation<*>) = DebugProbesImpl.probeCoroutineSuspen…
151 internal fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T> =
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DSharedFlow.kt225 var cont: Continuation<Unit>? = null // collector waiting for new value
233 override fun freeLocked(flow: SharedFlowImpl<*>): Array<Continuation<Unit>?> { in freeLocked()
323 var resumes: Array<Continuation<Unit>?> = EMPTY_RESUMES in tryEmit()
417 var resumes: Array<Continuation<Unit>?> = EMPTY_RESUMES in emitSuspend()
454 internal fun updateCollectorIndexLocked(oldIndex: Long): Array<Continuation<Unit>?> { in updateCollectorIndexLocked()
481 var resumes: Array<Continuation<Unit>?> = EMPTY_RESUMES in updateCollectorIndexLocked()
558 var resumes: Array<Continuation<Unit>?> = EMPTY_RESUMES in tryTakeValue()
606 …private fun findSlotsToResumeLocked(resumesIn: Array<Continuation<Unit>?>): Array<Continuation<Uni… in findSlotsToResumeLocked()
607 var resumes: Array<Continuation<Unit>?> = resumesIn in findSlotsToResumeLocked()
639 @JvmField val cont: Continuation<Unit> in fuse()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/
DCoroutineDispatcher.kt99 …blic final override fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T> = in isDispatchNeeded()
103 public override fun releaseInterceptedContinuation(continuation: Continuation<*>) { in isDispatchNeeded()
/external/kotlinx.atomicfu/atomicfu/src/jvmMain/kotlin/kotlinx/atomicfu/
DLockFreedomTestEnvironment.kt319 private var continuation: Continuation<Any?>? = null in <lambda>()
357 private fun resumeWith(result: Result<Any?>, continuation: Continuation<Any?>?) { in <lambda>()
383 private fun takeContinuation(): Continuation<Any?>? = in <lambda>()
397 override fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T> = in <lambda>()
398 Continuation<T>(this) { in <lambda>()
400 resumeWith(it, continuation as Continuation<Any?>) in <lambda>()
404 private val completion = Continuation<Unit>(interceptor) { in <lambda>()
/external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/api/
Dkotlinx-coroutines-jdk8.api5 …l fun await (Ljava/util/concurrent/CompletionStage;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
16 …public static final fun delay (Ljava/time/Duration;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
19 …java/time/Duration;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
20 …java/time/Duration;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/
DProbesSupport.common.kt9 internal expect inline fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T>
/external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/internal/
DProbesSupport.kt10 internal actual inline fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T> …
/external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/internal/
DProbesSupport.kt10 internal actual inline fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T> …

12345