kone.state/dev.lounres.kone.hub/KoneMutableAsynchronousHub

KoneMutableAsynchronousHub

interface KoneMutableAsynchronousHub<Value> : KoneAsynchronousHub<Value> (source)

Types

object Companion

Properties

abstract val callbacksValue: Value

val <Value> KoneAsynchronousHub<Value>.value: Value

Functions

abstract suspend fun acceptNewValue(newValue: Value)

abstract suspend fun acquire()

buildSubscriptionAtomic

inline fun <Value, Result> KoneAsynchronousHub<Value>.buildSubscriptionAtomic(valueEquality: Equality<Value> = Equality.absoluteFor(), builder: KoneAsynchronousHubAtomicSubscriptionScope<Value>.(Value) -> Result): Result

buildSubscriptionLocking

inline fun <Value, Result> KoneAsynchronousHub<Value>.buildSubscriptionLocking(builder: KoneAsynchronousHubBlockingSubscriptionScope<Value>.(Value) -> Result): Result

inline suspend fun <Value> KoneMutableAsynchronousHub<Value>.getAndUpdate(transform: (Value) -> Value): Value

lockCallbacksValue

abstract fun lockCallbacksValue()

fun <Value, Result> KoneAsynchronousHub<Value>.map(valueEquality: Equality<Value> = Equality.absoluteFor(), transform: (Value) -> Result): KoneMutableAsynchronousHub<Result>

abstract fun release()

suspend fun <Value> KoneMutableAsynchronousHub<Value>.set(newValue: Value)

@IgnorableReturnValue

abstract fun subscribe(callback: suspend (Value) -> Unit): KoneAsynchronousHub.Subscription

fun <Value> KoneAsynchronousHub<Value>.toStateFlow(): StateFlow<Value>

unlockCallbacksValue

abstract fun unlockCallbacksValue()

inline suspend fun <Value> KoneMutableAsynchronousHub<Value>.update(transform: (Value) -> Value)

inline suspend fun <Value> KoneMutableAsynchronousHub<Value>.updateAndGet(transform: (Value) -> Value): Value

inline suspend fun <Value, Result> KoneMutableAsynchronousHub<Value>.updateAndMap(transform: (Value) -> Value, map: (Value, Value) -> Result): Result

inline fun <SourceValue, TargetValue> KoneAsynchronousHub<SourceValue>.view(crossinline get: (SourceValue) -> TargetValue): KoneAsynchronousHub<TargetValue>

inline fun <SourceValue, TargetValue> KoneMutableAsynchronousHub<SourceValue>.view(crossinline get: (SourceValue) -> TargetValue, crossinline set: suspend (previousSourceValue: SourceValue, newTargetValue: TargetValue) -> SourceValue): KoneMutableAsynchronousHub<TargetValue>