korge/korlibs.korge.tests/TestCoroutineDispatcher

TestCoroutineDispatcher

class ~~TestCoroutineDispatcher~~(val frameTime: TimeSpan = 16.milliseconds) : CoroutineDispatcher, ContinuationInterceptor, Delay

Deprecated

Constructors

TestCoroutineDispatcher

constructor(frameTime: TimeSpan = 16.milliseconds)

Types

class TimedTask(val time: Long, val callback: suspend () -> Unit)

Properties

var exception: Throwable?

val frameTime: TimeSpan

open override val key: CoroutineContext.Key<*>

Functions

open suspend fun ~~delay~~(time: Long)

open override 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>

invokeOnTimeout

open fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): DisposableHandle

isDispatchNeeded

open fun isDispatchNeeded(context: CoroutineContext): Boolean

limitedParallelism

open fun limitedParallelism(parallelism: Int): CoroutineDispatcher

fun loop()

fun loop(entry: suspend () -> Unit)

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<*>)

scheduleResumeAfterDelay

open override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit>)

suspend fun ~~step~~(time: TimeSpan)

open override fun toString(): String