rd-core/com.jetbrains.rd.util.threading

Package com.jetbrains.rd.util.threading

Types

ByteBufferAsyncProcessor

class ByteBufferAsyncProcessor( val id: String, val chunkSize: Int = DefaultChunkSize, val processor: (ByteBufferAsyncProcessor.Chunk) -> Unit)

CompoundThrowable

class CompoundThrowable(errors: List<Throwable>) : Throwable

class Linearization

@ExperimentalCoroutinesApi

class QueueProcessor<T : Any>(val lifetime: Lifetime, process: suspend (T) -> Unit)

SingleThreadScheduler

class SingleThreadScheduler(val lifetime: Lifetime, val name: String) : SingleThreadSchedulerBase

SingleThreadSchedulerBase

abstract class SingleThreadSchedulerBase(val name: String) : IScheduler

SynchronousScheduler

object SynchronousScheduler : IScheduler

TestSingleThreadScheduler

class TestSingleThreadScheduler(val name: String) : SingleThreadSchedulerBase

Properties

val Executor.asRdScheduler: IScheduler

val CoroutineDispatcher.asRdScheduler: IScheduler