kone.state/dev.lounres.kone.hub/KoneMutableBlockingHub

KoneMutableBlockingHub

interface KoneMutableBlockingHub<Value> : KoneBlockingHub<Value> (source)

Types

object Companion

Properties

abstract val callbacksValue: Value

val <Value> KoneBlockingHub<Value>.value: Value

Functions

abstract fun acceptNewValue(newValue: Value)

abstract fun acquire()

buildSubscriptionAtomic

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

buildSubscriptionLocking

inline fun <Value, Result> KoneBlockingHub<Value>.buildSubscriptionLocking(builder: KoneBlockingHubBlockingSubscriptionScope<Value>.(Value) -> Result): Result

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

lockCallbacksValue

abstract fun lockCallbacksValue()

fun <Value, Result> KoneBlockingHub<Value>.map(valueEquality: Equality<Value> = Equality.defaultFor(), transform: (Value) -> Result): KoneMutableBlockingHub<Result>

abstract fun release()

fun <Value> KoneMutableBlockingHub<Value>.set(newValue: Value)

@IgnorableReturnValue

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

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

unlockCallbacksValue

abstract fun unlockCallbacksValue()

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

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

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

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

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