Package com.jetbrains.rd.util.threading

Types

Link copied to clipboard
class ByteBufferAsyncProcessor(    val id: String,     val chunkSize: Int = DefaultChunkSize,     val processor: (ByteBufferAsyncProcessor.Chunk) -> Unit)
Link copied to clipboard
class CompoundThrowable(errors: List<Throwable>) : Throwable
Link copied to clipboard
class Linearization
Link copied to clipboard
@ExperimentalCoroutinesApi
class QueueProcessor<T : Any>(val lifetime: Lifetime, process: suspend (T) -> Unit)
Link copied to clipboard
class SingleThreadScheduler(val lifetime: Lifetime, val name: String) : SingleThreadSchedulerBase
Link copied to clipboard
abstract class SingleThreadSchedulerBase(val name: String) : IScheduler
Link copied to clipboard
class SpinWait
Link copied to clipboard
object SynchronousScheduler : IScheduler
Link copied to clipboard
class TestSingleThreadScheduler(val name: String) : SingleThreadSchedulerBase

Properties

Link copied to clipboard
val Executor.asRdScheduler: IScheduler
val CoroutineDispatcher.asRdScheduler: IScheduler