Home
last modified time | relevance | path

Searched refs:CoroutineContext (Results 1 – 25 of 152) sorted by relevance

1234567

/external/kotlinx.coroutines/stdlib-stubs/src/
DCoroutineContext.kt7 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
DContinuationInterceptor.kt7 public interface ContinuationInterceptor : CoroutineContext.Element {
8 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/
DThreadContext.kt14 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/binary-compatibility-validator/reference-public-api/
Dkotlinx-coroutines-slf4j.txt7 …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…
Dkotlinx-coroutines-rx2.txt24 …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
32 …public static final fun asMaybe (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext;…
33 …ble (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/CoroutineContext;)Lio/reactive…
34 …public static final fun asSingle (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext
40 …public static final fun rxFlowable (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Func…
41 …n rxFlowable (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/f…
[all …]
Dkotlinx-coroutines-reactor.txt2 …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 …]
Dkotlinx-coroutines-core.txt2 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…
5 public final fun getContext ()Lkotlin/coroutines/CoroutineContext;
6 public fun getCoroutineContext ()Lkotlin/coroutines/CoroutineContext;
25 …al fun async (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coro…
26 …sync$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coro…
28 …l fun launch (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coro…
29 …unch$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coro…
30 …public static final fun runBlocking (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Fun…
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DFailingCoroutinesMachineryTest.kt17 private val element: CoroutineContext.Element, in <lambda>()
27 private object Key : CoroutineContext.Key<MyElement> in <lambda>()
29 override val key: CoroutineContext.Key<*> get() = Key in <lambda>()
31 override fun restoreThreadContext(context: CoroutineContext, oldState: Unit) { in <lambda>()
34 override fun updateThreadContext(context: CoroutineContext) { in <lambda>()
42 private object Key : CoroutineContext.Key<MyElement> in <lambda>()
44 override val key: CoroutineContext.Key<*> get() = Key in <lambda>()
46 override fun restoreThreadContext(context: CoroutineContext, oldState: Unit) { in <lambda>()
50 override fun updateThreadContext(context: CoroutineContext) { in <lambda>()
57 override fun dispatch(context: CoroutineContext, block: Runnable) { in <lambda>()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/
DCoroutineExceptionHandler.kt9 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()
69 public interface CoroutineExceptionHandler : CoroutineContext.Element {
73 public companion object Key : CoroutineContext.Key<CoroutineExceptionHandler>
79 public fun handleException(context: CoroutineContext, exception: Throwable)
DJob.kt84 public interface Job : CoroutineContext.Element {
88 public companion object Key : CoroutineContext.Key<Job> {
527 public val CoroutineContext.isActive: Boolean
534 public fun CoroutineContext.cancel(cause: CancellationException? = null) { in cancel()
542 public fun CoroutineContext.cancel() = cancel(null) in cancel()
574 public fun CoroutineContext.ensureActive(): Unit { in ensureActive()
589 public fun CoroutineContext.cancel(cause: Throwable? = null): Boolean = in cancel()
598 public fun CoroutineContext.cancelChildren(cause: CancellationException? = null) { in cancel()
606 public fun CoroutineContext.cancelChildren() = cancelChildren(null) in cancelChildren()
612 public fun CoroutineContext.cancelChildren(cause: Throwable? = null) { in cancelChildren()
DBuilders.common.kt46 context: CoroutineContext = EmptyCoroutineContext, in <lambda>()
81 context: CoroutineContext = EmptyCoroutineContext, in async()
95 parentContext: CoroutineContext,
106 parentContext: CoroutineContext, in getCompleted()
137 context: CoroutineContext, in withContext()
180 parentContext: CoroutineContext, in invoke()
190 parentContext: CoroutineContext,
204 context: CoroutineContext,
216 context: CoroutineContext,
DCoroutineContext.common.kt13 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?
DCoroutineScope.kt58 public val coroutineContext: CoroutineContext in <lambda>()
67 public operator fun CoroutineScope.plus(context: CoroutineContext): CoroutineScope = in plus()
138 override val coroutineContext: CoroutineContext in plus()
191 public fun CoroutineScope(context: CoroutineContext): CoroutineScope = in CoroutineScope()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/
DCoroutineContext.kt32 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/common/src/flow/internal/
DChannelFlow.kt26 @JvmField val context: CoroutineContext, in <lambda>()
31 context: CoroutineContext = EmptyCoroutineContext, in <lambda>()
56 protected abstract fun create(context: CoroutineContext, capacity: Int): ChannelFlow<T> in <lambda>()
88 context: CoroutineContext,
94 …end fun collectWithContextUndispatched(collector: FlowCollector<T>, newContext: CoroutineContext) { in flowCollect()
128 context: CoroutineContext = EmptyCoroutineContext, in toString()
131 override fun create(context: CoroutineContext, capacity: Int): ChannelFlow<T> = in toString()
140 private fun <T> FlowCollector<T>.withUndispatchedContextCollector(emitContext: CoroutineContext): F… in withUndispatchedContextCollector()
149 private val emitContext: CoroutineContext
160 newContext: CoroutineContext, in emit()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
DIntegrationTest.kt23 …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/
DIntegrationTest.kt23 …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/ui/kotlinx-coroutines-android/android-unit-tests/src/
DEmptyCoroutineScopeImpl.kt4 import kotlin.coroutines.CoroutineContext
9 override val coroutineContext: CoroutineContext
14 override val coroutineContext: CoroutineContext
19 override val coroutineContext: CoroutineContext
/external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/
DCoroutineContext.kt14 override fun dispatch(context: CoroutineContext, block: Runnable) = in takeEventLoop()
31 public actual fun CoroutineScope.newCoroutineContext(context: CoroutineContext): CoroutineContext { in loopWasShutDown()
38 internal actual inline fun <T> withCoroutineContext(context: CoroutineContext, countOrElement: Any?…
40 internal actual val CoroutineContext.coroutineName: String? get() = null // not supported on native
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/
DCatchTest.kt100 val d0 = coroutineContext[ContinuationInterceptor] as CoroutineContext in <lambda>()
108 … assertSame(d1, kotlin.coroutines.coroutineContext[ContinuationInterceptor] as CoroutineContext) in <lambda>()
116 … assertSame(d1, kotlin.coroutines.coroutineContext[ContinuationInterceptor] as CoroutineContext) in <lambda>()
123 … assertSame(d1, kotlin.coroutines.coroutineContext[ContinuationInterceptor] as CoroutineContext) in <lambda>()
130 … assertSame(d2, kotlin.coroutines.coroutineContext[ContinuationInterceptor] as CoroutineContext) in <lambda>()
143 … assertSame(d0, kotlin.coroutines.coroutineContext[ContinuationInterceptor] as CoroutineContext) in <lambda>()
/external/kotlinx.coroutines/integration/kotlinx-coroutines-slf4j/src/
DMDCContext.kt10 import kotlin.coroutines.CoroutineContext
51 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()
/external/kotlinx.coroutines/kotlinx-coroutines-test/src/
DTestCoroutineScope.kt27 override val coroutineContext: CoroutineContext in cleanupTestCoroutines()
49 public fun TestCoroutineScope(context: CoroutineContext = EmptyCoroutineContext): TestCoroutineScop… in TestCoroutineScope()
56 private inline val CoroutineContext.uncaughtExceptionCaptor: UncaughtExceptionCaptor
65 private inline val CoroutineContext.delayController: DelayController
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/
DCoroutineDispatcherOperatorFunInvokeTest.kt8 import kotlin.coroutines.CoroutineContext
64 override fun dispatch(context: CoroutineContext, block: Runnable) { in String()
69 override fun isDispatchNeeded(context: CoroutineContext): Boolean { in String()
74 override fun dispatchYield(context: CoroutineContext, block: Runnable) { in String()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/test_/
DTestCoroutineContext.kt36 class TestCoroutineContext(private val name: String? = null) : CoroutineContext { in <lambda>()
61 public override fun <R> fold(initial: R, operation: (R, CoroutineContext.Element) -> R): R = in <lambda>()
65 … public override fun <E : CoroutineContext.Element> get(key: CoroutineContext.Key<E>): E? = when { in <lambda>()
71 public override fun minusKey(key: CoroutineContext.Key<*>): CoroutineContext = when { in <lambda>()
220 override fun dispatch(context: CoroutineContext, block: Runnable) { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/
DCoroutineContext.kt44 public actual fun CoroutineScope.newCoroutineContext(context: CoroutineContext): CoroutineContext { in isJsdom()
51 internal actual inline fun <T> withCoroutineContext(context: CoroutineContext, countOrElement: Any?…
53 internal actual val CoroutineContext.coroutineName: String? get() = null // not supported on JS

1234567