| /external/kotlinx.coroutines/kotlinx-coroutines-debug/src/internal/ |
| D | NoOpProbes.kt | 15 internal fun probeCoroutineResumedNoOp(frame: Continuation<*>) = Unit
17 internal fun probeCoroutineSuspendedNoOp(frame: Continuation<*>) = Unit
19 …eCoroutineCreatedNoOp(completion: kotlin.coroutines.Continuation<T>): kotlin.coroutines.Continuati…
|
| D | DebugProbesImpl.kt | 258 internal fun probeCoroutineResumed(frame: Continuation<*>) = updateState(frame, State.RUNNING) in <lambda>()
260 … internal fun probeCoroutineSuspended(frame: Continuation<*>) = updateState(frame, State.SUSPENDED) in <lambda>()
262 private fun updateState(frame: Continuation<*>, state: State) { in <lambda>()
289 info.updateState(state, frame as Continuation<*>) in <lambda>()
301 private fun updateState(owner: CoroutineOwner<*>, frame: Continuation<*>, state: State) { in <lambda>()
306 … private fun Continuation<*>.owner(): CoroutineOwner<*>? = (this as? CoroutineStackFrame)?.owner() in <lambda>() method
311 internal fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T> { in <lambda>()
337 …private fun <T> createOwner(completion: Continuation<T>, frame: CoroutineStackFrame): Continuation… in <lambda>()
361 @JvmField val delegate: Continuation<T>, in <lambda>()
364 ) : Continuation<T> by delegate, CoroutineStackFrame by frame { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/intrinsics/ |
| D | Undispatched.kt | 17 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()
|
| D | Cancellable.kt | 16 public fun <T> (suspend () -> T).startCoroutineCancellable(completion: Continuation<T>) = runSafely… in <lambda>()
24 …fun <R, T> (suspend (R) -> T).startCoroutineCancellable(receiver: R, completion: Continuation<T>) = in startCoroutineCancellable()
35 private inline fun runSafely(completion: Continuation<*>, block: () -> Unit) { in runSafely()
|
| /external/kotlinx.coroutines/stdlib-stubs/src/ |
| D | ContinuationInterceptor.kt | 9 public fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T> in interceptContinuation()
10 public fun releaseInterceptedContinuation(continuation: Continuation<*>): Continuation<*> { in interceptContinuation()
|
| /external/kotlinx.coroutines/binary-compatibility-validator/reference-public-api/ |
| D | kotlinx-coroutines-rx2.txt | 2 …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 …]
|
| D | kotlinx-coroutines-core.txt | 1 …/AbstractCoroutine : kotlinx/coroutines/JobSupport, kotlin/coroutines/Continuation, kotlinx/corout…
18 …public static final fun awaitAll (Ljava/util/Collection;Lkotlin/coroutines/Continuation;)Ljava/lan…
19 …public static final fun awaitAll ([Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/Continuation;)L…
20 …public static final fun joinAll (Ljava/util/Collection;Lkotlin/coroutines/Continuation;)Ljava/lang…
21 …public static final fun joinAll ([Lkotlinx/coroutines/Job;Lkotlin/coroutines/Continuation;)Ljava/l…
27 …oroutineDispatcher;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
32 …s/CoroutineContext;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
35 …tract interface class kotlinx/coroutines/CancellableContinuation : kotlin/coroutines/Continuation {
56 public fun <init> (Lkotlin/coroutines/Continuation;I)V
81 …cellableCoroutine (Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
[all …]
|
| D | kotlinx-coroutines-reactive.txt | 2 …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…
11 …estreams/Publisher;Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
12 …estreams/Publisher;Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
62 public fun send (Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
|
| D | kotlinx-coroutines-jdk8.txt | 5 …l fun await (Ljava/util/concurrent/CompletionStage;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
11 …public static final fun delay (Ljava/time/Duration;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
13 …java/time/Duration;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
14 …java/time/Duration;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Obj…
|
| D | kotlinx-coroutines-javafx.txt | 2 public fun delay (JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
9 public static final fun awaitPulse (Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
|
| D | kotlinx-coroutines-android.txt | 2 public fun delay (JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
8 public static final fun awaitFrame (Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Dispatched.kt | 78 @JvmField val continuation: Continuation<T>
79 ) : DispatchedTask<T>(MODE_ATOMIC_DEFAULT), CoroutineStackFrame, Continuation<T> by continuation { in <lambda>()
95 override val delegate: Continuation<T> in <lambda>()
183 internal fun <T> Continuation<T>.resumeCancellable(value: T) = when (this) { in resumeCancellable()
188 internal fun <T> Continuation<T>.resumeCancellableWithException(exception: Throwable) = when (this)… in resumeCancellableWithException()
193 internal fun <T> Continuation<T>.resumeDirect(value: T) = when (this) { in resumeDirect()
198 internal fun <T> Continuation<T>.resumeDirectWithException(exception: Throwable) = when (this) { in resumeDirectWithException()
206 internal abstract val delegate: Continuation<T>
305 internal fun <T> DispatchedTask<T>.resume(delegate: Continuation<T>, useMode: Int) { in resume()
325 internal inline fun Continuation<*>.resumeWithStackTrace(exception: Throwable) { in resumeWithStackTrace()
|
| D | ResumeMode.kt | 19 internal fun <T> Continuation<T>.resumeMode(value: T, mode: Int) { in resumeMode()
30 internal fun <T> Continuation<T>.resumeWithExceptionMode(exception: Throwable, mode: Int) { in resumeWithExceptionMode()
41 internal fun <T> Continuation<T>.resumeUninterceptedMode(value: T, mode: Int) { in resumeUninterceptedMode()
52 internal fun <T> Continuation<T>.resumeUninterceptedWithExceptionMode(exception: Throwable, mode: I… in resumeUninterceptedWithExceptionMode()
|
| D | CoroutineDispatcher.kt | 101 …blic final override fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T> =
|
| D | CoroutineStart.kt | 88 public operator fun <T> invoke(block: suspend () -> T, completion: Continuation<T>) = in invoke()
107 …ic operator fun <R, T> invoke(block: suspend R.() -> T, receiver: R, completion: Continuation<T>) = in invoke()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | CancellableContinuationTest.kt | 14 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>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/src/ |
| D | DebugProbes.kt | 126 internal fun probeCoroutineResumed(frame: Continuation<*>) = DebugProbesImpl.probeCoroutineResumed(…
128 internal fun probeCoroutineSuspended(frame: Continuation<*>) = DebugProbesImpl.probeCoroutineSuspen…
129 …probeCoroutineCreated(completion: kotlin.coroutines.Continuation<T>): kotlin.coroutines.Continuati…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | DelayJvmTest.kt | 60 override fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T> = in <lambda>()
64 class Wrapper<T>(val pool: Executor, private val cont: Continuation<T>) : Continuation<T> { in <lambda>()
|
| D | ContinuationSerializationTest.kt | 71 …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-core/common/test/selects/ |
| D | SelectBuilderImplTest.kt | 16 val delegate = object : Continuation<String> { in testIdempotentSelectResumeInline()
41 val delegate = object : Continuation<String> { in testIdempotentSelectResumeSuspended()
66 val delegate = object : Continuation<String> { in testIdempotentSelectResumeWithExceptionInline()
96 val delegate = object : Continuation<String> { in testIdempotentSelectResumeWithExceptionSuspended()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | ProbesSupport.common.kt | 9 internal expect inline fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T>
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/internal/ |
| D | ProbesSupport.kt | 10 internal actual inline fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T> …
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/internal/ |
| D | ProbesSupport.kt | 10 internal actual inline fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T> …
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/internal/ |
| D | ProbesSupport.kt | 11 internal actual inline fun <T> probeCoroutineCreated(completion: Continuation<T>): Continuation<T> …
|
| /external/swiftshader/third_party/llvm-7.0/llvm/include/llvm/Support/ |
| D | TaskQueue.h | 110 std::function<void()> Continuation; in completeTask() local
118 Continuation = std::move(Tasks.front()); in completeTask()
121 Scheduler.async(std::move(Continuation)); in completeTask()
|