ktor-network/io.ktor.network.util/IOCoroutineDispatcher

IOCoroutineDispatcher

~~class~~ ~~IOCoroutineDispatcher~~(~~nThreads~~: Int) : ~~CoroutineDispatcher~~, ~~Closeable~~

Default ktor fixed size dispatcher for doing non-blocking I/O operations and selection

Constructors

IOCoroutineDispatcher

fun IOCoroutineDispatcher(nThreads: Int)

Functions

open override fun close()

Gracefully shutdown dispatcher.

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

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

isDispatchNeeded

open fun isDispatchNeeded(context: CoroutineContext): Boolean

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

open operator fun plus(context: CoroutineContext): CoroutineContext

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

releaseInterceptedContinuation

open override fun releaseInterceptedContinuation(continuation: Continuation<*>)

open override fun toString(): String

Properties

open override val key: CoroutineContext.Key<*>