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

Package com.jetbrains.rd.util.threading.coroutines

Types

RdCoroutineScope

open class RdCoroutineScope : CoroutineScope

Functions

adviseSuspend

fun <T> ISource<T>.adviseSuspend( lifetime: Lifetime, scheduler: IScheduler, handler: suspend (T) -> Unit)

fun <T> ISource<T>.adviseSuspend( lifetime: Lifetime, context: CoroutineContext, handler: suspend (T) -> Unit)

asCoroutineDispatcher

~~fun~~ IScheduler.~~asCoroutineDispatcher~~(allowInlining: Boolean): CoroutineDispatcher

async

fun <T> Lifetime.async( scheduler: IScheduler, start: CoroutineStart = CoroutineStart.DEFAULT, block: suspend CoroutineScope.() -> T): Deferred<T>

fun <T> Lifetime.async( context: CoroutineContext = EmptyCoroutineContext, start: CoroutineStart = CoroutineStart.DEFAULT, block: suspend CoroutineScope.() -> T): Deferred<T>

createTerminatedAfter

fun Lifetime.createTerminatedAfter(duration: Duration, terminationContext: CoroutineContext): Lifetime

launch

fun Lifetime.launch( scheduler: IScheduler, start: CoroutineStart = CoroutineStart.DEFAULT, block: suspend CoroutineScope.() -> Unit): Job

fun Lifetime.launch( context: CoroutineContext = EmptyCoroutineContext, start: CoroutineStart = CoroutineStart.DEFAULT, block: suspend CoroutineScope.() -> Unit): Job

lifetimedCoroutineScope

suspend fun <T> lifetimedCoroutineScope(lifetime: Lifetime, action: suspend CoroutineScope.() -> T): T

Creates a coroutineScope that will be cancelled on the passed lifetime termination

nextFalseValue

suspend fun ISource<Boolean>.nextFalseValue(): Boolean

nextFalseValueAsync

fun ISource<Boolean>.nextFalseValueAsync(lifetime: Lifetime): Deferred<Boolean>

nextNotNullValue

suspend fun <T : Any> ISource<T?>.nextNotNullValue(): T

nextNotNullValueAsync

fun <T : Any> ISource<T?>.nextNotNullValueAsync(lifetime: Lifetime): Deferred<T>

nextTrueValue

suspend fun ISource<Boolean>.nextTrueValue(): Boolean

nextTrueValueAsync

fun ISource<Boolean>.nextTrueValueAsync(lifetime: Lifetime): Deferred<Boolean>

nextValue

suspend fun <T> ISource<T>.nextValue(condition: (T) -> Boolean = { true }): T

nextValueAsync

fun <T> ISource<T>.nextValueAsync(lifetime: Lifetime, condition: (T) -> Boolean = { true }): Deferred<T>

noAwait

fun Job.noAwait()

synchronizeWith

fun LifetimeDefinition.synchronizeWith(scope: CoroutineScope, supportsTerminationUnderExecution: Boolean = false)

fun LifetimeDefinition.synchronizeWith(job: Job, supportsTerminationUnderExecution: Boolean = false)

waitFor

suspend fun waitFor( timeout: Duration, maxDelay: Long = 256, lifetime: Lifetime = Lifetime.Eternal, condition: suspend () -> Boolean): Boolean

withLifetime

suspend fun withLifetime(context: CoroutineContext = EmptyCoroutineContext, action: suspend CoroutineScope.(Lifetime) -> Unit)

The same as withContext, but creates a Lifetime that will be terminated only after the passed action and its CoroutineScope are completed

withRdSchedulerContext

suspend fun <T> withRdSchedulerContext(scheduler: IScheduler, block: suspend CoroutineScope.() -> T): T

Properties

asCoroutineDispatcher

val IScheduler.asCoroutineDispatcher: CoroutineDispatcher