/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 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/binary-compatibility-validator/reference-public-api/ |
D | kotlinx-coroutines-slf4j.txt | 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…
|
D | kotlinx-coroutines-rx2.txt | 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… 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 …]
|
D | kotlinx-coroutines-reactor.txt | 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 …]
|
D | kotlinx-coroutines-core.txt | 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… 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/ |
D | FailingCoroutinesMachineryTest.kt | 17 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/ |
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() 69 public interface CoroutineExceptionHandler : CoroutineContext.Element { 73 public companion object Key : CoroutineContext.Key<CoroutineExceptionHandler> 79 public fun handleException(context: CoroutineContext, exception: Throwable)
|
D | Job.kt | 84 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()
|
D | Builders.common.kt | 46 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,
|
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 | 58 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/ |
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/common/src/flow/internal/ |
D | ChannelFlow.kt | 26 @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/ |
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/ui/kotlinx-coroutines-android/android-unit-tests/src/ |
D | EmptyCoroutineScopeImpl.kt | 4 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/ |
D | CoroutineContext.kt | 14 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/ |
D | CatchTest.kt | 100 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/ |
D | MDCContext.kt | 10 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/ |
D | TestCoroutineScope.kt | 27 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/ |
D | CoroutineDispatcherOperatorFunInvokeTest.kt | 8 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_/ |
D | TestCoroutineContext.kt | 36 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/ |
D | CoroutineContext.kt | 44 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
|