DispatcherWithShutdown

class DispatcherWithShutdown(delegate: CoroutineDispatcher) : CoroutineDispatcher

Specialized dispatcher useful for graceful shutdown

Constructors

fun DispatcherWithShutdown(delegate: CoroutineDispatcher)

Complete shutdown. Any further attempts to dispatch anything will fail with RejectedExecutionException

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

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

Prepare for shutdown so we will not dispatch on delegate anymore. It is still possible to dispatch coroutines.

open override fun toString(): String