modulecheck-utils:coroutines:api/modulecheck.utils.coroutines/LimitedDispatcher

LimitedDispatcher

abstract class LimitedDispatcher : CoroutineDispatcher(source)

An abstract marker representing the limitParallelism(...) functionality in coroutines 1.6.x, which is forked here

Since

0.12.0

Constructors

LimitedDispatcher

constructor()

Properties

open override val key: CoroutineContext.Key<*>

Functions

abstract fun dispatch(context: CoroutineContext, block: Runnable)

open fun dispatchYield(context: CoroutineContext, block: Runnable)

open override fun <R> fold(initial: R, operation: (R, CoroutineContext.Element) -> R): R

open operator override fun <E : CoroutineContext.Element> get(key: CoroutineContext.Key<E>): E?

interceptContinuation

override fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T>

isDispatchNeeded

open fun isDispatchNeeded(context: CoroutineContext): Boolean

limitedParallelism

open fun limitedParallelism(parallelism: Int): CoroutineDispatcher

open override fun minusKey(key: CoroutineContext.Key<*>): CoroutineContext

open operator fun plus(context: CoroutineContext): CoroutineContext

operator fun ~~plus~~(other: CoroutineDispatcher): CoroutineDispatcher

releaseInterceptedContinuation

override fun releaseInterceptedContinuation(continuation: Continuation<*>)

open override fun toString(): String