| /external/kotlinx.coroutines/stdlib-stubs/src/ |
| D | CoroutineContext.kt | 7 public interface CoroutineContext { interface
10 public operator fun plus(context: CoroutineContext): CoroutineContext = TODO() in get()
11 public fun minusKey(key: Key<*>): CoroutineContext in get()
13 public interface Element : CoroutineContext { in get()
23 public override fun minusKey(key: Key<*>): CoroutineContext = in get()
28 public object EmptyCoroutineContext : CoroutineContext {
32 public override fun <E : CoroutineContext.Element> get(key: CoroutineContext.Key<E>): E? = null
33 …public override fun <R> fold(initial: R, operation: (R, CoroutineContext.Element) -> R): R = initi…
34 public override fun plus(context: CoroutineContext): CoroutineContext = context
35 public override fun minusKey(key: CoroutineContext.Key<*>): CoroutineContext = this
|
| D | ContinuationInterceptor.kt | 7 public interface ContinuationInterceptor : CoroutineContext.Element {
8 public companion object Key : CoroutineContext.Key<ContinuationInterceptor>
13 …public override operator fun <E : CoroutineContext.Element> get(key: CoroutineContext.Key<E>): E? …
14 public override fun minusKey(key: CoroutineContext.Key<*>): CoroutineContext = TODO()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/internal/ |
| D | ThreadContext.kt | 14 private class ThreadState(val context: CoroutineContext, n: Int) {
26 fun (countOrElement: Any?, element: CoroutineContext.Element): Any? { in <anonymous>()
36 …fun (found: ThreadContextElement<*>?, element: CoroutineContext.Element): ThreadContextElement<*>?… in <anonymous>()
43 fun (state: ThreadState, element: CoroutineContext.Element): ThreadState { in <anonymous>()
52 fun (state: ThreadState, element: CoroutineContext.Element): ThreadState { in <anonymous>()
60 internal actual fun threadContextElements(context: CoroutineContext): Any = context.fold(0, countAl… in threadContextElements()
63 internal fun updateThreadContext(context: CoroutineContext, countOrElement: Any?): Any? { in threadContextElements()
83 internal fun restoreThreadContext(context: CoroutineContext, oldState: Any?) { in restoreThreadContext()
102 internal data class ThreadLocalKey(private val threadLocal: ThreadLocal<*>) : CoroutineContext.Key<…
108 override val key: CoroutineContext.Key<*> = ThreadLocalKey(threadLocal)
[all …]
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-slf4j/api/ |
| D | kotlinx-coroutines-slf4j.api | 7 …public fun get (Lkotlin/coroutines/CoroutineContext$Key;)Lkotlin/coroutines/CoroutineContext$Eleme…
9 public fun minusKey (Lkotlin/coroutines/CoroutineContext$Key;)Lkotlin/coroutines/CoroutineContext;
10 public fun plus (Lkotlin/coroutines/CoroutineContext;)Lkotlin/coroutines/CoroutineContext;
11 public synthetic fun restoreThreadContext (Lkotlin/coroutines/CoroutineContext;Ljava/lang/Object;)V
12 public fun restoreThreadContext (Lkotlin/coroutines/CoroutineContext;Ljava/util/Map;)V
13 public synthetic fun updateThreadContext (Lkotlin/coroutines/CoroutineContext;)Ljava/lang/Object;
14 public fun updateThreadContext (Lkotlin/coroutines/CoroutineContext;)Ljava/util/Map;
17 public final class kotlinx/coroutines/slf4j/MDCContext$Key : kotlin/coroutines/CoroutineContext$Key…
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/api/ |
| D | kotlinx-coroutines-rx2.api | 24 …public static final fun rxCompletable (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/F…
25 …xCompletable (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/f…
26 …public static synthetic fun rxCompletable$default (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm…
27 …able$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/f…
31 …public static final fun asCompletable (Lkotlinx/coroutines/Job;Lkotlin/coroutines/CoroutineContext…
33 …al fun asFlowable (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;)Lio/reactive…
34 …sFlowable$default (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;ILjava/lang/O…
35 …public static final fun asMaybe (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext;…
36 …ble (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/CoroutineContext;)Lio/reactive…
37 … fun asObservable (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;)Lio/reactive…
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | FailingCoroutinesMachineryTest.kt | 17 private val element: CoroutineContext.Element, in <lambda>()
40 private object Key : CoroutineContext.Key<MyElement> in <lambda>()
42 override val key: CoroutineContext.Key<*> get() = Key in <lambda>()
44 override fun restoreThreadContext(context: CoroutineContext, oldState: Unit) { in <lambda>()
47 override fun updateThreadContext(context: CoroutineContext) { in <lambda>()
55 private object Key : CoroutineContext.Key<MyElement> in <lambda>()
57 override val key: CoroutineContext.Key<*> get() = Key in <lambda>()
59 override fun restoreThreadContext(context: CoroutineContext, oldState: Unit) { in <lambda>()
63 override fun updateThreadContext(context: CoroutineContext) { in <lambda>()
70 override fun dispatch(context: CoroutineContext, block: Runnable) { in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/api/ |
| D | kotlinx-coroutines-reactor.api | 2 …lux (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/CoroutineContext;)Lreactor/cor…
3 …ult (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/CoroutineContext;ILjava/lang/O…
4 …public static final fun asMono (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext;)…
5 …public static final fun asMono (Lkotlinx/coroutines/Job;Lkotlin/coroutines/CoroutineContext;)Lreac…
13 …public static final fun flux (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;…
14 …nal fun flux (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/f…
15 …public static synthetic fun flux$default (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/function…
16 …flux$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/f…
20 …public static final fun mono (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;…
21 …nal fun mono (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/f…
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CoroutineExceptionHandler.kt | 9 internal expect fun handleCoroutineExceptionImpl(context: CoroutineContext, exception: Throwable) in handleCoroutineExceptionImpl()
21 public fun handleCoroutineException(context: CoroutineContext, exception: Throwable) { in handleCoroutineExceptionImpl()
48 public inline fun CoroutineExceptionHandler(crossinline handler: (CoroutineContext, Throwable) -> U… in CoroutineExceptionHandler()
50 override fun handleException(context: CoroutineContext, exception: Throwable) = in CoroutineExceptionHandler()
98 public interface CoroutineExceptionHandler : CoroutineContext.Element {
102 public companion object Key : CoroutineContext.Key<CoroutineExceptionHandler>
108 public fun handleException(context: CoroutineContext, exception: Throwable)
|
| D | Job.kt | 112 public interface Job : CoroutineContext.Element {
116 public companion object Key : CoroutineContext.Key<Job> {
555 public val CoroutineContext.isActive: Boolean
562 public fun CoroutineContext.cancel(cause: CancellationException? = null) { in cancel()
570 public fun CoroutineContext.cancel(): Unit = cancel(null) in cancel()
602 public fun CoroutineContext.ensureActive() { in ensureActive()
616 public fun CoroutineContext.cancel(cause: Throwable? = null): Boolean { in cancel()
627 public fun CoroutineContext.cancelChildren(cause: CancellationException? = null) { in cancelChildren()
635 public fun CoroutineContext.cancelChildren(): Unit = cancelChildren(null) in cancelChildren()
644 public val CoroutineContext.job: Job get() = get(Job) ?: error("Current context doesn't contain Job… in cancelChildren()
[all …]
|
| D | Builders.common.kt | 48 context: CoroutineContext = EmptyCoroutineContext, in <lambda>()
83 context: CoroutineContext = EmptyCoroutineContext, in async()
97 parentContext: CoroutineContext,
108 parentContext: CoroutineContext, in getCompleted()
138 context: CoroutineContext, in withContext()
185 parentContext: CoroutineContext, in invoke()
195 parentContext: CoroutineContext,
207 context: CoroutineContext,
225 context: CoroutineContext,
|
| D | CoroutineContext.common.kt | 13 public expect fun CoroutineScope.newCoroutineContext(context: CoroutineContext): CoroutineContext
21 internal expect inline fun <T> withCoroutineContext(context: CoroutineContext, countOrElement: Any?…
23 internal expect val CoroutineContext.coroutineName: String?
|
| D | CoroutineScope.kt | 72 public val coroutineContext: CoroutineContext in <lambda>()
81 public operator fun CoroutineScope.plus(context: CoroutineContext): CoroutineScope = in plus()
150 override val coroutineContext: CoroutineContext in plus()
206 public fun CoroutineScope(context: CoroutineContext): CoroutineScope = in CoroutineScope()
259 public suspend inline fun currentCoroutineContext(): CoroutineContext = coroutineContext
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/api/ |
| D | kotlinx-coroutines-rx3.api | 22 …public static final fun rxCompletable (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/F…
23 …public static synthetic fun rxCompletable$default (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm…
27 …public static final fun asCompletable (Lkotlinx/coroutines/Job;Lkotlin/coroutines/CoroutineContext…
29 …al fun asFlowable (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;)Lio/reactive…
30 …sFlowable$default (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;ILjava/lang/O…
31 …public static final fun asMaybe (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext;…
32 … fun asObservable (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;)Lio/reactive…
33 …bservable$default (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;ILjava/lang/O…
34 …public static final fun asSingle (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext…
37 …ynthetic fun from (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;)Lio/reactive…
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/flow/internal/ |
| D | SafeCollector.kt | 23 @JvmField internal actual val collectContext: CoroutineContext in <lambda>()
32 private var lastEmissionContext: CoroutineContext? = null in <lambda>()
36 override val context: CoroutineContext in <lambda>()
81 currentContext: CoroutineContext, in <lambda>()
82 previousContext: CoroutineContext?, in <lambda>()
128 internal class DownstreamExceptionElement(@JvmField val e: Throwable) : CoroutineContext.Element {
129 companion object Key : CoroutineContext.Key<DownstreamExceptionElement>
131 override val key: CoroutineContext.Key<*> = Key
135 override val context: CoroutineContext = EmptyCoroutineContext
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | CoroutineContext.kt | 32 public actual fun CoroutineScope.newCoroutineContext(context: CoroutineContext): CoroutineContext { in createDefaultDispatcher()
42 internal actual inline fun <T> withCoroutineContext(context: CoroutineContext, countOrElement: Any?… in withCoroutineContext()
51 internal actual val CoroutineContext.coroutineName: String? get() {
63 companion object Key : CoroutineContext.Key<CoroutineId>
66 override fun updateThreadContext(context: CoroutineContext): String { in toString()
82 override fun restoreThreadContext(context: CoroutineContext, oldState: String) { in restoreThreadContext()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | CoroutineContext.kt | 15 override fun dispatch(context: CoroutineContext, block: Runnable) = in takeEventLoop()
19 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in takeEventLoop()
33 public actual fun CoroutineScope.newCoroutineContext(context: CoroutineContext): CoroutineContext { in loopWasShutDown()
40 internal actual inline fun <T> withCoroutineContext(context: CoroutineContext, countOrElement: Any?…
42 internal actual val CoroutineContext.coroutineName: String? get() = null // not supported on native
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | ChannelFlow.kt | 31 context: CoroutineContext = EmptyCoroutineContext, in <lambda>()
48 @JvmField public val context: CoroutineContext,
73 …public override fun fuse(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflo… in dropChannelOperators()
106 …protected abstract fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOv… in create()
154 context: CoroutineContext,
161 …end fun collectWithContextUndispatched(collector: FlowCollector<T>, newContext: CoroutineContext) { in flowCollect()
197 context: CoroutineContext = EmptyCoroutineContext, in toString()
201 …override fun create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): C… in toString()
212 private fun <T> FlowCollector<T>.withUndispatchedContextCollector(emitContext: CoroutineContext): F… in withUndispatchedContextCollector()
221 private val emitContext: CoroutineContext
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxConvert.kt | 30 public fun Job.asCompletable(context: CoroutineContext): Completable = rxCompletable(context) { in <lambda>()
47 public fun <T> Deferred<T?>.asMaybe(context: CoroutineContext): Maybe<T> = rxMaybe(context) { in <lambda>()
64 public fun <T : Any> Deferred<T>.asSingle(context: CoroutineContext): Single<T> = rxSingle(context)… in <lambda>()
108 public fun <T: Any> Flow<T>.asObservable(context: CoroutineContext = EmptyCoroutineContext) : Obser… in asObservable()
141 public fun <T: Any> Flow<T>.asFlowable(context: CoroutineContext = EmptyCoroutineContext): Flowable… in asFlowable()
149 public fun <T : Any> ReceiveChannel<T>.asObservable(context: CoroutineContext): Observable<T> = rxO… in asFlowable()
158 public fun <T: Any> Flow<T>._asFlowable(context: CoroutineContext = EmptyCoroutineContext): Flowabl…
165 public fun <T: Any> Flow<T>._asObservable(context: CoroutineContext = EmptyCoroutineContext) : Obse…
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | IntegrationTest.kt | 23 …MAIN { override fun invoke(context: CoroutineContext): CoroutineContext = context.minusKey(… in <lambda>()
24 …DEFAULT { override fun invoke(context: CoroutineContext): CoroutineContext = Dispatchers.Defau… in <lambda>()
25 …UNCONFINED { override fun invoke(context: CoroutineContext): CoroutineContext = Dispatchers.Uncon… in <lambda>()
27 abstract operator fun invoke(context: CoroutineContext): CoroutineContext in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | IntegrationTest.kt | 23 …MAIN { override fun invoke(context: CoroutineContext): CoroutineContext = context.minusKey(… in <lambda>()
24 …DEFAULT { override fun invoke(context: CoroutineContext): CoroutineContext = Dispatchers.Defau… in <lambda>()
25 …UNCONFINED { override fun invoke(context: CoroutineContext): CoroutineContext = Dispatchers.Uncon… in <lambda>()
27 abstract operator fun invoke(context: CoroutineContext): CoroutineContext in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | IntegrationTest.kt | 23 …MAIN { override fun invoke(context: CoroutineContext): CoroutineContext = context.minusKey(… in <lambda>()
24 …DEFAULT { override fun invoke(context: CoroutineContext): CoroutineContext = Dispatchers.Defau… in <lambda>()
25 …UNCONFINED { override fun invoke(context: CoroutineContext): CoroutineContext = Dispatchers.Uncon… in <lambda>()
27 abstract operator fun invoke(context: CoroutineContext): CoroutineContext in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxConvert.kt | 30 public fun Job.asCompletable(context: CoroutineContext): Completable = rxCompletable(context) { in <lambda>()
47 public fun <T> Deferred<T?>.asMaybe(context: CoroutineContext): Maybe<T> = rxMaybe(context) { in <lambda>()
64 public fun <T : Any> Deferred<T>.asSingle(context: CoroutineContext): Single<T> = rxSingle(context)… in <lambda>()
108 public fun <T: Any> Flow<T>.asObservable(context: CoroutineContext = EmptyCoroutineContext) : Obser… in asObservable()
141 public fun <T: Any> Flow<T>.asFlowable(context: CoroutineContext = EmptyCoroutineContext): Flowable…
148 public fun <T: Any> Flow<T>._asFlowable(context: CoroutineContext = EmptyCoroutineContext): Flowabl…
155 public fun <T: Any> Flow<T>._asObservable(context: CoroutineContext = EmptyCoroutineContext) : Obse…
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | IntegrationTest.kt | 22 …MAIN { override fun invoke(context: CoroutineContext): CoroutineContext = context.minusKey(… in <lambda>()
23 …DEFAULT { override fun invoke(context: CoroutineContext): CoroutineContext = Dispatchers.Defau… in <lambda>()
24 …UNCONFINED { override fun invoke(context: CoroutineContext): CoroutineContext = Dispatchers.Uncon… in <lambda>()
26 abstract operator fun invoke(context: CoroutineContext): CoroutineContext in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 2 protected final field parentContext Lkotlin/coroutines/CoroutineContext;
3 public fun <init> (Lkotlin/coroutines/CoroutineContext;Z)V
4 …public synthetic fun <init> (Lkotlin/coroutines/CoroutineContext;ZILkotlin/jvm/internal/DefaultCon…
7 public final fun getContext ()Lkotlin/coroutines/CoroutineContext;
8 public fun getCoroutineContext ()Lkotlin/coroutines/CoroutineContext;
27 …al fun async (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coro…
28 …sync$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coro…
30 …l fun launch (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coro…
31 …unch$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coro…
32 …public static final fun runBlocking (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Fun…
[all …]
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-slf4j/src/ |
| D | MDCContext.kt | 10 import kotlin.coroutines.CoroutineContext
51 public companion object Key : CoroutineContext.Key<MDCContext>
54 override fun updateThreadContext(context: CoroutineContext): MDCContextMap { in updateThreadContext()
61 override fun restoreThreadContext(context: CoroutineContext, oldState: MDCContextMap) { in restoreThreadContext()
|