rd-core/com.jetbrains.rd.util.lifetime/Lifetime

Lifetime

sealed class Lifetime

Types

object Companion

Functions

~~fun~~ ~~add~~(action: () -> Unit)

abstract fun attach(child: LifetimeDefinition, inheritTimeoutKind: Boolean)

~~fun~~ <T : Any> ~~bracket~~(opening: () -> T, terminationAction: () -> Unit): T?

abstract fun <T : Any> bracketIfAlive(opening: () -> T, terminationAction: () -> Unit): T?

bracketIfAliveEx

abstract fun <T : Any> bracketIfAliveEx(opening: () -> T, terminationAction: (T) -> Unit): T?

abstract fun <T : Any> bracketOrThrow(opening: () -> T, terminationAction: () -> Unit): T

bracketOrThrowEx

abstract fun <T : Any> bracketOrThrowEx(opening: () -> T, terminationAction: (T) -> Unit): T

fun createNested(): LifetimeDefinition

fun createNested(atomicAction: (LifetimeDefinition) -> Unit): LifetimeDefinition

createNestedDef

~~fun~~ ~~createNestedDef~~(): LifetimeDefinition

abstract fun <T : Any> executeIfAlive(action: () -> T): T?

abstract fun <T : Any> executeOrThrow(action: () -> T): T

~~fun~~ <T : Any> ~~ifAlive~~(action: () -> T): T?

abstract fun onTermination(closeable: Closeable)

abstract fun onTermination(action: () -> Unit)

onTerminationIfAlive

abstract fun onTerminationIfAlive(closeable: Closeable): Boolean

abstract fun onTerminationIfAlive(action: () -> Unit): Boolean

inline fun <T> usingNested(action: (Lifetime) -> T): T

Properties

allowTerminationUnderExecution

abstract val allowTerminationUnderExecution: Boolean

abstract val coroutineScope: CoroutineScope

~~val~~ ~~isTerminated~~: Boolean

abstract val status: LifetimeStatus

terminationTimeoutKind

abstract val terminationTimeoutKind: LifetimeTerminationTimeoutKind

Inheritors

LifetimeDefinition

Extensions

fun Lifetime.assertAlive()

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

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

createTerminatedAfter

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

defineIntersection

fun Lifetime.defineIntersection(lifetime: Lifetime): LifetimeDefinition

fun Lifetime.intersect(lifetime: Lifetime): Lifetime

Creates an intersection of some lifetimes: new lifetime that terminate when either one terminates. Created lifetime inherits the smallest terminationTimeoutKind

val Lifetime.isAlive: Boolean

val Lifetime.isEternal: Boolean

val Lifetime.isNotAlive: Boolean

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

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

~~fun~~ Lifetime.~~onTermination~~(action: () -> Unit)

~~fun~~ Lifetime.~~onTermination~~(closeable: Closeable)

operator fun Lifetime.plusAssign(action: () -> Unit)

throwIfNotAlive

fun Lifetime.throwIfNotAlive()

inline fun <T> Lifetime.view(viewable: IViewable<T>, crossinline handler: Lifetime.(T) -> Unit)

inline fun <T : Any> Lifetime.viewNotNull(viewable: IViewable<T?>, crossinline handler: Lifetime.(T) -> Unit)

waitTermination

fun Lifetime.waitTermination()