2025.2.2-beta1

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

Package-level declarations

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

Functions

fun Executor.asRdScheduler(executionOrder: ExecutionOrder): IScheduler

fun CoroutineDispatcher.asRdScheduler(dispatcherExecutionOrder: ExecutionOrder): IScheduler

asSequentialScheduler

fun IScheduler.asSequentialScheduler(): IScheduler

Transforms the current scheduler into a sequential one.